Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
Leiten Sie eingehende Datensätze an eine einzelne Iceberg-Tabelle weiter
Wenn Sie möchten, dass Firehose Daten in eine einzelne Iceberg-Tabelle einfügt, konfigurieren Sie einfach eine einzelne Datenbank und Tabelle in Ihrer Stream-Konfiguration, wie im folgenden Beispiel gezeigt. JSON Für eine einzelne Tabelle benötigen Sie keinen JQ-Ausdruck und keine Lambda-Funktion, um die Routing-Informationen für Firehose bereitzustellen. Wenn Sie diese Felder zusammen mit JQ oder Lambda angeben, nimmt Firehose Eingaben von JQ oder Lambda entgegen.
[ { "DestinationDatabaseName": "UserEvents", "DestinationTableName": "customer_id", "UniqueKeys": [ "COLUMN_PLACEHOLDER" ], "S3ErrorOutputPrefix": "OPTIONAL_PREFIX_PLACEHOLDER" } ]
In diesem Beispiel leitet Firehose alle Eingabedatensätze an eine customer_id
Tabelle in der UserEvents
Datenbank weiter. Wenn Sie Aktualisierungs- oder Löschvorgänge für eine einzelne Tabelle ausführen möchten, müssen Sie Firehose die Operation für jeden eingehenden Datensatz entweder mit der JSONQueryMethode oder der Lambda-Methode zur Verfügung stellen.