Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
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 JSON seguente. 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.
