cief/dbt_cloud
1
0
Fork 0
mirror of https://gitlab.com/cief-data/dbt_cloud.git synced 2026-08-19 04:14:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Change name

Browse Source
This commit is contained in:
Yam ZhengLim
2023-08-02 04:12:14 +00:00
parent 22723bdd05
commit 973f835d15
1 changed files with 0 additions and 78 deletions
Download Patch File Download Diff File Expand all files Collapse all files
models/staging/googlesheet/stg_googlesheet__sales_team_lead_activations.sql
-78
View File
@@ -1,78 +0,0 @@
-- IMPORT
WITH lead_activations AS (
SELECT * FROM {{ source('src_googlesheet_airbyte', '_airbyte_raw_leads_activations') }}
),
-- LOGIC
parse_json_leads AS (
SELECT
_airbyte_ab_id AS sales_team_lead_activation_id,
parse_json(_airbyte_data) AS leads_json,
_airbyte_emitted_at AS _airbyte_emitted_datetime
FROM lead_activations
),
flatten_json AS (
SELECT
sales_team_lead_activation_id,
leads_json['agent_name']::STRING AS agent_name,
leads_json['company_marking']::STRING AS company_marking_id,
leads_json['contact_number']::STRING AS contact_number,
leads_json['email']::STRING AS contact_email,
leads_json['sorce']::STRING AS contact_method,
leads_json['tag']::STRING AS contact_status,
leads_json['user_name']::STRING AS contact_name,
leads_json['remark']::STRING AS sales_team_remark,
COALESCE(
TRY_TO_TIMESTAMP(leads_json['contacted_datetime']::STRING, 'DD-MM-YYYY'),
TRY_TO_TIMESTAMP(leads_json['contacted_datetime']::STRING, 'DD-MM-YYYY HH24:MI:SS')
) AS sales_team_contacted_datetime,
COALESCE(
TRY_TO_TIMESTAMP(leads_json['register_date']::STRING, 'DD-MM-YYYY'),
TRY_TO_TIMESTAMP(leads_json['register_date']::STRING, 'DD-MM-YYYY HH24:MI:SS')
) AS exchange_registered_datetime,
COALESCE(
TRY_TO_TIMESTAMP(leads_json['user_first_reply_datetime']::STRING, 'DD-MM-YYYY'),
TRY_TO_TIMESTAMP(leads_json['user_first_reply_datetime']::STRING, 'DD-MM-YYYY HH24:MI:SS')
) AS first_reply_datetime,
_airbyte_emitted_datetime,
'{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime
FROM parse_json_leads
),
-- FINAL
final__stg_googlesheet__sales_team_lead_activations AS (
SELECT
-- ids
sales_team_lead_activation_id,
-- dimensions
company_marking_id,
agent_name,
contact_name,
contact_number,
contact_email,
contact_method,
contact_status,
sales_team_remark,
-- measures
-- date/times
sales_team_contacted_datetime,
first_reply_datetime,
exchange_registered_datetime,
-- metadata
_airbyte_emitted_datetime,
_dbt_ran_datetime
FROM flatten_json
)
SELECT * FROM final__stg_googlesheet__sales_team_lead_activations