Encaminhamento dos registros recebidos para uma única tabela do Iceberg - Amazon Data Firehose

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Encaminhamento dos registros recebidos para uma única tabela do Iceberg

Se você quiser que o Firehose insira dados em uma única tabela Iceberg, basta configurar um único banco de dados e tabela na configuração do stream, conforme mostrado no exemplo a seguir. JSON Para uma única tabela, você não precisa da expressão JQ e da função do Lambda para fornecer as informações de encaminhamento ao Firehose. Se você fornecer esses campos junto com o JQ ou o Lambda, o Firehose receberá informações do JQ ou do Lambda.

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

Neste exemplo, o Firehose encaminha todos os registros de entrada para a tabela customer_id no banco de dados UserEvents. Se você quiser realizar operações de atualização ou exclusão em uma única tabela, precisará fornecer a operação para cada registro de entrada ao Firehose usando o método ou JSONQueryo método Lambda.