fraudtwin.BronzeRecord#

class fraudtwin.BronzeRecord(run_id, source, subject, table_name, record_id, record_key, contract_fingerprint, payload, raw_payload_b64, headers, event_time, received_at, kafka_topic=None, kafka_partition=None, kafka_offset=None)[source][source]#

Bases: object

Canonical raw-record envelope used by both ingestion paths.

Parameters:

  • run_id (str)

  • source (str)

  • subject (str)

  • table_name (str)

  • record_id (str)

  • record_key (str | None)

  • contract_fingerprint (str | None)

  • payload (dict[str, Any])

  • raw_payload_b64 (str | None)

  • headers (dict[str, str])

  • event_time (str | None)

  • received_at (str)

  • kafka_topic (str | None)

  • kafka_partition (int | None)

  • kafka_offset (int | None)