Simple Log Service:ログデータの変更と削除

RowID

RowID とは、行レベルの更新と削除が有効になっている Logstore に書き込まれた各ログエントリに SLS が割り当てる論理的なレコード識別子です。すべての変更および削除操作は、RowID を使用してターゲットレコードを特定します。

• 形式：SLS は書き込み時に RowID を生成します。RowID をカスタマイズまたは構築することはできません。不透明な識別子として扱ってください。

• 安定性：RowID はログレコードのライフサイクル全体を通じて変更されません。レコードを変更した後でも、同じ RowID がそのレコードを指し続けます。

• 可視性：この機能が有効になっている Logstore からのクエリ結果には、組み込みフィールド __rowid__ が自動的に含まれます。これは予約されたフィールド名であり、インデックス設定では使用できません。

AffectedRows

変更または削除リクエストが成功するたびに AffectedRows が返されます。これは、操作が実際に影響を与えたログレコードの数を示します。この値を使用して、操作が期待どおりに実行されたことを確認してください。

OpenAPI による有効化

CreateLogStore API を呼び出し、リクエストボディで enableModify を true に設定します。

POST /logstores HTTP/1.1
Host: <project>.<endpoint>
Content-Type: application/json

{
  "logstoreName": "my-logstore",
  "ttl": 30,
  "shardCount": 1,
  "enableModify": true
}

Logstore を作成した後、GetLogStore API を呼び出して確認します。レスポンスボディに "enableModify": true が含まれていれば、機能が有効になっています。

Python SDK による有効化

from aliyun.log import LogClient

# 環境変数から AccessKey 認証情報を取得します。
client = LogClient(endpoint, access_key_id, access_key)

client.create_logstore(
    project_name="my-project",
    logstore_name="my-logstore",
    ttl=30,
    shard_count=1,
    enable_modify=True,
)

方法 1: RowID による変更と削除

特定のレコードの RowID を既に持っている場合 (通常は以前のクエリ結果から取得) に、この方法を使用します。

from aliyun.log import LogClient, LogItem

client = LogClient(endpoint, access_key_id, access_key)

# 更新するフィールドのみを指定します。指定されていないフィールドは元の値を保持します。
new_item = LogItem(
    contents=[("status", "REFUNDED")],
)

resp = client.update_logs(
    project="my-project",
    logstore="my-logstore",
    rowid=rowid,
    log_item=new_item,
)
print(f"Affected rows: {resp.affected_rows}")

resp = client.delete_logs_v2(
    project="my-project",
    logstore="my-logstore",
    rowid=rowid,
)
print(f"Affected rows: {resp.affected_rows}")

方法 2: クエリによる変更と削除

クエリ条件に一致するレコードを一括変更または一括削除する場合に、この方法を使用します。SLS はサーバー側でクエリを実行し、一致するすべてのレコードに対して変更または削除を適用します。

resp = client.delete_logs_v2(
    project="my-project",
    logstore="my-logstore",
    from_time=1716537600,
    to_time=1716624000,
    query='level: DEBUG',
)
print(f"Deleted rows: {resp.affected_rows}")

resp = client.update_logs(
    project="my-project",
    logstore="my-logstore",
    from_time=1716537600,
    to_time=1716624000,
    query='order_id: 12345 and status: "PENDING"',
    update_fields={"status": "REFUNDED", "refund_at": "2026-05-25T10:00:00Z"},
)
print(f"Modified rows: {resp.affected_rows}")

既存の Logstore に対してこの機能を有効にできますか?

いいえ。この機能は、Logstore 作成時にのみ利用可能な基盤となるストレージ形式に依存しています。この機能を使用するには、enableModify=true で新しい Logstore を作成し、データ変換または SDK を通じて履歴データを新しい Logstore に移行してください。

変更および削除操作はリアルタイムコンシューマーに影響しますか?

いいえ。LogHub コンシューマーと配信タスク (OSS や MaxCompute への配信など) は、元の書き込みストリームで動作し、変更や削除を反映しません。クエリベースの読み取りパス (検索、SQL、SPL) のみが最新のデータを返します。

変更と削除は即座に反映されますか？

はい。リクエストが成功した後、新しいクエリは更新されたデータを返します。レスポンスの AffectedRows 値は、実際に変更または削除されたレコードの数を示します。

誤った変更または削除をロールバックできますか?

いいえ。組み込みのロールバック機能はありません。変更または削除操作を実行する前に、検索または SQL を使用してクエリ条件に一致するレコードをプレビューしてください。これらの操作には、制限された権限を持つ専用の RAM ユーザーを使用し、監査のために ActionTrail を有効にすることを推奨します。

削除により即座にストレージ領域が解放されますか？

削除は論理操作です。基盤となるストレージは、Logstore の Time to Live (TTL) が期限切れになるか、バックグラウンドのコンパクションタスクが実行されるまで保持されます。ただし、すべてのクエリパスは削除されたレコードをフィルタリングするため、削除されたデータはユーザーには表示されません。