Enrutamiento de los registros entrantes a una sola tabla de Iceberg

Si quieres que Firehose inserte datos en una sola tabla de Iceberg, simplemente configura una sola base de datos y una tabla en tu configuración de flujo, como se muestra en el siguiente ejemplo. JSON En el caso de una sola tabla, no se necesita la expresión JQ ni la función de Lambda para proporcionar la información de enrutamiento a Firehose. Si proporciona estos campos junto con JQ o Lambda, Firehose tomará la entrada de JQ o Lambda.

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

En este ejemplo, Firehose enruta todos los registros de entrada a la tabla de customer_id en la base de datos UserEvents. Si desea realizar operaciones de actualización o eliminación en una sola tabla, debe proporcionar la operación para cada registro entrante a Firehose mediante el método o el JSONQuerymétodo Lambda.