Acheminer les enregistrements entrants vers une seule table Iceberg - Amazon Data Firehose

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Acheminer les enregistrements entrants vers une seule table Iceberg

Si vous souhaitez que Firehose insère des données dans une seule table Iceberg, il vous suffit de configurer une seule base de données et une seule table dans votre configuration de flux, comme indiqué dans l'exemple suivant. JSON Pour une table unique, vous n'avez pas besoin d'expression JQ ni de fonction Lambda pour fournir les informations de routage à Firehose. Si vous fournissez ces champs avec JQ ou Lambda, Firehose prendra les entrées de JQ ou Lambda.

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

Dans cet exemple, Firehose achemine tous les enregistrements d'entrée vers une customer_id table dans UserEvents la base de données. Si vous souhaitez effectuer des opérations de mise à jour ou de suppression sur une seule table, vous devez fournir l'opération pour chaque enregistrement entrant à Firehose en utilisant la méthode ou la JSONQueryméthode Lambda.