수신 레코드를 단일 Iceberg 테이블로 라우팅 - Amazon Data Firehose

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

수신 레코드를 단일 Iceberg 테이블로 라우팅

Firehose가 단일 Iceberg 테이블에 데이터를 삽입하도록 하려면 다음 예시 JSON과 같이 스트림 구성에서 단일 데이터베이스와 테이블을 구성하기만 하면 됩니다. 단일 테이블의 경우 Firehose에 라우팅 정보를 제공하기 위해 JQ 표현식 및 Lambda 함수가 필요하지 않습니다. 이러한 필드를 JQ 또는 Lambda와 함께 제공하는 경우 Firehose는 JQ 또는 Lambda에서 입력을 받습니다.

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

이 예시에서는 Firehose가 모든 입력 레코드를 UserEvents 데이터베이스의 customer_id 테이블에 라우팅합니다. 단일 테이블에서 업데이트 또는 삭제 작업을 수행하려면 JSONQuery 메서드 또는 Lambda 메서드를 사용하여 Firehose에 수신되는 각 레코드에 대한 작업을 제공해야 합니다.