feat(analytics): Add ckh columns for 3ds intelligence analytics (#8136)

Co-authored-by: hyperswitch-bot[bot] <148525504+hyperswitch-bot[bot]@users.noreply.github.com>
This commit is contained in:
Sahkal Poddar
2025-05-28 19:16:43 +05:30
committed by GitHub
parent 1acf525a46
commit 4ad0492a88

View File

@ -36,7 +36,29 @@ CREATE TABLE authentication_queue (
`directory_server_id` Nullable(String),
`acquirer_country_code` Nullable(String),
`organization_id` String,
`sign_flag` Int8
`sign_flag` Int8,
`mcc` Nullable(String),
`amount` Nullable(UInt32),
`currency` LowCardinality(Nullable(String)),
`merchant_country` LowCardinality(Nullable(String)),
`billing_country` LowCardinality(Nullable(String)),
`shipping_country` LowCardinality(Nullable(String)),
`issuer_country` LowCardinality(Nullable(String)),
`earliest_supported_version` LowCardinality(Nullable(String)),
`latest_supported_version` LowCardinality(Nullable(String)),
`whitelist_decision` Nullable(Bool),
`device_manufacturer` Nullable(String),
`platform` LowCardinality(Nullable(String)),
`device_type` LowCardinality(Nullable(String)),
`device_brand` Nullable(String),
`device_os` Nullable(String),
`device_display` Nullable(String),
`browser_name` Nullable(String),
`browser_version` Nullable(String),
`issuer_id` Nullable(String),
`scheme_name` Nullable(String),
`exemption_requested` Nullable(Bool),
`exemption_accepted` Nullable(Bool),
) ENGINE = Kafka SETTINGS kafka_broker_list = 'kafka0:29092',
kafka_topic_list = 'hyperswitch-authentication-events',
kafka_group_name = 'hyper',
@ -83,6 +105,28 @@ CREATE TABLE authentications (
`acquirer_country_code` Nullable(String),
`organization_id` String,
`sign_flag` Int8,
`mcc` Nullable(String),
`amount` Nullable(UInt32),
`currency` LowCardinality(Nullable(String)),
`merchant_country` LowCardinality(Nullable(String)),
`billing_country` LowCardinality(Nullable(String)),
`shipping_country` LowCardinality(Nullable(String)),
`issuer_country` LowCardinality(Nullable(String)),
`earliest_supported_version` LowCardinality(Nullable(String)),
`latest_supported_version` LowCardinality(Nullable(String)),
`whitelist_decision` Nullable(Bool),
`device_manufacturer` Nullable(String),
`platform` LowCardinality(Nullable(String)),
`device_type` LowCardinality(Nullable(String)),
`device_brand` Nullable(String),
`device_os` Nullable(String),
`device_display` Nullable(String),
`browser_name` Nullable(String),
`browser_version` Nullable(String),
`issuer_id` Nullable(String),
`scheme_name` Nullable(String),
`exemption_requested` Nullable(Bool),
`exemption_accepted` Nullable(Bool),
INDEX authenticationConnectorIndex authentication_connector TYPE bloom_filter GRANULARITY 1,
INDEX transStatusIndex trans_status TYPE bloom_filter GRANULARITY 1,
INDEX authenticationTypeIndex authentication_type TYPE bloom_filter GRANULARITY 1,
@ -130,7 +174,29 @@ CREATE MATERIALIZED VIEW authentication_mv TO authentications (
`directory_server_id` Nullable(String),
`acquirer_country_code` Nullable(String),
`organization_id` String,
`sign_flag` Int8
`sign_flag` Int8,
`mcc` Nullable(String),
`amount` Nullable(UInt32),
`currency` LowCardinality(Nullable(String)),
`merchant_country` LowCardinality(Nullable(String)),
`billing_country` LowCardinality(Nullable(String)),
`shipping_country` LowCardinality(Nullable(String)),
`issuer_country` LowCardinality(Nullable(String)),
`earliest_supported_version` LowCardinality(Nullable(String)),
`latest_supported_version` LowCardinality(Nullable(String)),
`whitelist_decision` Nullable(Bool),
`device_manufacturer` Nullable(String),
`platform` LowCardinality(Nullable(String)),
`device_type` LowCardinality(Nullable(String)),
`device_brand` Nullable(String),
`device_os` Nullable(String),
`device_display` Nullable(String),
`browser_name` Nullable(String),
`browser_version` Nullable(String),
`issuer_id` Nullable(String),
`scheme_name` Nullable(String),
`exemption_requested` Nullable(Bool),
`exemption_accepted` Nullable(Bool),
) AS
SELECT
authentication_id,
@ -171,7 +237,29 @@ SELECT
directory_server_id,
acquirer_country_code,
organization_id,
sign_flag
sign_flag,
mcc,
amount,
currency,
merchant_country,
billing_country,
shipping_country,
issuer_country,
earliest_supported_version,
latest_supported_version,
whitelist_decision,
device_manufacturer,
platform,
device_type,
device_brand,
device_os,
device_display,
browser_name,
browser_version,
issuer_id,
scheme_name,
exemption_requested,
exemption_accepted
FROM
authentication_queue
WHERE