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

概要

デフォルトでは、Logstore は追記専用の不変モデルに従います。データが Logstore に書き込まれた後は、その場で変更または削除することはできません。

一部のシナリオでは、Logstore 内の既存データを変更または削除する必要があります。

• フィールドの事後修正：元のログが書き込まれた後に、注文ステータス、リスクラベル、スコアリング結果などのビジネスフィールドを更新します。

• テストデータのクリーンアップ：本番環境の Logstore からテストレコードまたはカナリアレコードを削除します。

• 単一レコードの修復：ビジネスのリプレイまたは照合ワークフロー中に特定のログエントリを修正します。

Simple Log Service は、Logstore 単位で 行レベルの更新と削除 機能を提供します。RowID による個別レコードの変更・削除、またはクエリによるレコードの一括変更・削除が可能です。

基本概念

前提条件

以下の要件が満たされていることを確認してください。

• Simple Log Service プロジェクトが作成されていること。詳細については、「プロジェクトの作成」をご参照ください。

• enableModify パラメータが true に設定された Logstore が作成されていること。本トピックの「機能の有効化」をご参照ください。

• 呼び出し元に log:UpdateLogStoreLogs および log:DeleteLogStoreLogs の RAM 権限が付与されていること。本トピックの「必要な RAM 権限」をご参照ください。

• (条件付き) クエリベースの操作を使用する場合、クエリで参照されるフィールドにインデックスが設定されている必要があります。

機能の有効化

行レベルの更新と削除を使用するには、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
}

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,
)

データの変更と削除

ログデータの変更と削除には、2 つの方法があります。

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}")

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}")

結果の確認

各変更または削除操作の後に結果を確認し、期待どおりに成功したことを確認してください。

• AffectedRows の確認：各リクエストは、レスポンスで AffectedRows を返します (HTTP レスポンスボディの x-log-affectedrows または Python SDK の resp.affected_rows)。この値を期待されるレコード数と比較してください。

  • AffectedRows > 0 で期待値と一致する場合：操作が成功しました。

  • AffectedRows = 0 の場合：条件に一致するレコードがないか、レコードがすでに削除されています。クエリまたは RowID を再確認してください。

  • AffectedRows が期待値より少ない場合：部分的な失敗が発生した可能性があります。残りのレコードに対して操作を再実行してください。

• フォローアップクエリの実行：一括操作の場合、操作後に Search または SQL クエリを実行して、データが期待どおりの状態になっていることを確認してください。これは、AffectedRows が期待値より少ない場合に特に重要です。

データ整合性

変更および削除操作は同期的に反映されます。リクエストが成功した後、後続のクエリ (Search、SQL、SPL) は更新された結果を返します。

以下の動作に注意してください。

• リアルタイム消費は影響を受けません：LogHub コンシューマーおよび配信タスク (OSS または MaxCompute への配信など) は、元の書き込みストリームで動作します。これらは変更または削除を反映しません。クエリベースの読み取りパスのみが最新のデータを返します。

• クエリベースの操作はアトミックではありません：サーバーは一致する各レコードを個別に処理します。部分的な失敗が発生した場合、すでに処理されたレコードはロールバックされません。レスポンスには、実際に影響を受けた行数が返されます。

必要な RAM 権限

変更または削除 API を呼び出す RAM ユーザーまたはロールには、以下の権限が必要です。

リソース ARN 形式：

acs:log:<region>:<account-id>:project/<project-name>/logstore/<logstore-name>

制限事項

課金

• 変更操作：変更操作は現在課金されません。将来的には、変更されたデータによって生成されるストレージ容量に基づいて課金されます。

• 削除操作：削除操作には追加料金は発生しません。

よくある質問