將傳入記錄路由至單一 Iceberg 資料表

如果您想要 Firehose 將資料插入單一 Iceberg 資料表，只需在串流組態中設定單一資料庫和資料表，如下列範例 JSON 所示。對於單一資料表，您不需要 JQ 表達式和 Lambda 函數來提供路由資訊給 Firehose。如果您將這些欄位與 JQ 或 Lambda 一起提供，則 Firehose 將從 JQ 或 Lambda 取得輸入。

[
  {
    "DestinationDatabaseName": "UserEvents",
    "DestinationTableName": "customer_id",
    "UniqueKeys": [
      "COLUMN_PLACEHOLDER"
    ],
    "S3ErrorOutputPrefix": "OPTIONAL_PREFIX_PLACEHOLDER"
  }
]

在此範例中，Firehose 將所有輸入記錄路由到UserEvents資料庫中的customer_id資料表。如果您想要在單一資料表上執行更新或刪除操作，則需要使用 JSONQuery 方法或 Lambda 方法將每個傳入記錄的操作提供給 Firehose。