CREATE SINK insights.account_groups_ft_sink AS
SELECT
account_group_id,
fact_date,
purchasing_power,
purchasing_power_system_currency,
created_at,
updated_at,
disabled_at,
disabled_reason
FROM olap.account_groups_ft
WHERE
disabled_at IS NULL
WITH (
connector='postgres',
host='psql-nonprod-uae-derived.postgres.database.azure.com',
port='6432',
user='migration_user',
password='***',
database='adib-int-insights-db',
table='account_groups_ft',
schema='insights',
type='upsert',
force_compaction='true',
primary_key='account_group_id,fact_date'
)