Indirizza i record in entrata a una singola tabella Iceberg

Se desideri che Firehose inserisca dati in una singola tabella Iceberg, configura semplicemente un singolo database e una singola tabella nella configurazione dello stream, come mostrato nell'esempio seguente. JSON Per una singola tabella, non sono necessarie l'espressione JQ e la funzione Lambda per fornire le informazioni di routing a Firehose. Se fornisci questi campi insieme a JQ o Lambda, Firehose riceverà input da JQ o Lambda.

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

In questo esempio, Firehose indirizza tutti i record di input alla customer_id tabella del database. UserEvents Se si desidera eseguire operazioni di aggiornamento o eliminazione su una singola tabella, è necessario fornire l'operazione per ogni record in entrata a Firehose utilizzando il metodo o JSONQueryil metodo Lambda.