Skip to content

이벤트 전달 의미론

이 페이지에서는 커런츠가 데이터 웨어하우스 스토리지 파트너에게 보내는 플랫 파일 이벤트 데이터를 관리하는 방법을 간략하게 설명하고 정의합니다.

데이터 스토리지용 커런츠는 플랫폼에서 데이터 웨어하우스 파트너 연결 중 하나에 있는 스토리지 버킷으로 데이터를 지속적으로 스트리밍하는 것입니다. 커런츠는 일정한 임계값에 따라 Avro 파일을 스토리지 버킷에 기록하여 자체 비즈니스 인텔리전스(BI) 도구 세트로 이벤트 데이터를 처리하고 분석할 수 있도록 합니다.

테스트 이벤트

커런츠 통합을 설정할 때, 테스트 이벤트 전송을 클릭하여 스토리지 버킷과의 연결을 확인하세요. 이 테스트 이벤트는 통합이 데이터를 올바르게 수신하고 처리할 수 있는지 검증합니다.

최소 한 번 이상 전달

처리량이 많은 시스템인 커런츠는 이벤트를 “최소 한 번” 전달하므로, 중복된 이벤트가 스토리지 버킷에 기록될 수 있습니다. 이는 어떤 이유로든 이벤트가 대기줄에서 재처리될 때 발생할 수 있습니다.

사용 사례에 “정확히 한 번” 전달이 필요한 경우, 모든 이벤트와 함께 전송되는 고유 식별자 필드(id)를 사용하여 이벤트를 중복 제거할 수 있습니다. 파일이 스토리지 버킷에 기록되면 Braze의 제어를 벗어나므로, Braze 측에서 중복 제거를 보장할 수 있는 방법은 없습니다.

타임스탬프

커런츠에서 내보내는 모든 타임스탬프는 UTC 시간대로 전송됩니다. 일부 이벤트에서는 시간대 필드도 포함되어 있으며, 이벤트 발생 시점의 사용자 로컬 시간대를 IANA(Internet Assigned Numbers Authority) 형식으로 제공합니다.

지연 시간

SDK 또는 API를 통해 Braze로 전송된 이벤트에는 과거의 타임스탬프가 포함될 수 있습니다. 가장 대표적인 예는 모바일 연결이 없는 경우처럼 SDK 데이터가 대기줄에 쌓이는 경우입니다. 이 경우 이벤트 타임스탬프는 이벤트가 생성된 시점을 반영합니다. 따라서 일정 비율의 이벤트가 높은 지연 시간을 보이는 것처럼 나타날 수 있습니다.

Apache Avro 형식

Braze 커런츠 데이터 스토리지 통합은 .avro 형식으로 데이터를 출력합니다. Apache Avro를 선택한 이유는 스키마 진화를 기본적으로 지원하는 유연한 데이터 형식이며, 다양한 데이터 제품에서 지원되기 때문입니다:

  • Avro는 거의 모든 주요 데이터 웨어하우스에서 지원됩니다.
  • 데이터를 S3에 그대로 보관하려는 경우, Avro는 CSV 및 JSON보다 압축률이 높아 스토리지 비용이 절감되고 데이터 구문 분석에 필요한 CPU 사용량도 줄일 수 있습니다.
  • Avro는 데이터를 쓰거나 읽을 때 스키마가 필요합니다. 스키마는 시간이 지남에 따라 진화할 수 있어 기존 기능을 손상시키지 않고 필드를 추가할 수 있습니다.

커런츠는 다음 형식을 사용하여 각 이벤트 유형에 대한 파일을 생성합니다:

1

<your-bucket-prefix>/dataexport.<cluster-identifier>.<connection-type-identifier>.integration.<integration-id>/event_type=<event-type>/date=<date>/version=<currents_version>/<environment>/dataexport.<cluster-identifier>.<connection-type-identifier>.integration.<integration-id>+<partition>+<offset>.avro

예를 들어, 푸시 전송 이벤트 경로는 다음과 같을 수 있습니다:

1

currents-export/dataexport.prod-01.S3.integration.69cadaaed2d51b7c75b1a3e5/event_type=users.messages.pushnotification.Send/date=2025-04-01-17/version=6/us-01/dataexport.prod-01.S3.integration.69cadaaed2d51b7c75b1a3e5+0+123456.avro

version 경로 세그먼트는 version=6과 같은 단순 정수 커런츠 버전 값입니다.

Avro 쓰기 임계값

정상적인 상황에서 Braze는 5분마다 또는 15,000개의 이벤트 중 먼저 도달하는 조건에 따라 스토리지 버킷에 데이터 파일을 기록합니다. 부하가 높은 경우, 파일당 최대 100,000개의 이벤트가 포함된 더 큰 데이터 파일을 기록할 수 있습니다.

Avro 스키마 변경

Braze는 필드가 추가, 변경 또는 제거될 때 Avro 스키마를 변경할 수 있습니다. 여기서는 두 가지 유형의 변경이 있습니다: 호환 변경과 비호환 변경. 모든 스키마 변경은 커런츠 릴리스에 번들로 포함되며, 각 릴리스는 스토리지 경로의 version=<currents_version> 세그먼트를 업데이트합니다(예: version=6에서 version=7으로). Azure Blob Storage, Google Cloud Storage, Amazon S3에 기록되는 커런츠 이벤트는 다음 경로 형식을 사용합니다:

1

<your-bucket-prefix>/<currents-integration-id>/event_type=<event-type>/date=<date>/version=<currents_version>/<environment>/<avro-file>

호환 변경

Avro 스키마에 필드가 추가되면 이를 호환 변경으로 간주합니다. 추가된 필드는 항상 “선택 사항”인 Avro 필드(예: 기본값이 null)이므로, Avro 스키마 해석 사양에 따라 이전 스키마와 “일치”합니다. 이러한 추가는 기존 ETL(Extract, Transform, and Load) 프로세스에 영향을 미치지 않으며, 해당 필드가 ETL 프로세스에 추가될 때까지 단순히 무시됩니다.

비호환 변경

Avro 스키마에서 필드가 제거되거나 변경되면 이를 비호환 변경으로 간주합니다. 비호환 변경은 사용 중이던 필드가 더 이상 예상대로 기록되지 않을 수 있으므로 기존 ETL 프로세스의 수정이 필요할 수 있습니다.

모든 비호환 변경은 릴리스 전에 사전 공지됩니다.

버전별 변경 이력 전체를 확인하려면 커런츠 체인지로그를 참조하세요.
New Stuff!