WFの例#
まずは、本章で実行する WF を紹介しておこう。
id_unification_ex4.dig#
+call_unification:
http_call>: https://api-cdp.treasuredata.com/unifications/workflow_call
headers:
- authorization: ${secret:td.apikey}
method: POST
retry: true
content_format: json
content:
run_canonical_ids: true
run_enrichments: true
run_master_tables: true
full_refresh: true
keep_debug_tables: true
unification:
!include : unification_ex4.yml
unification_ex4.yml#
name: test_id_unification_ex4
keys:
- name: member_id
- name: email
tables:
- database: test_id_unification_ex4
table: site_aaa
key_columns:
- {column: member_id, key: member_id}
- {column: email, key: email}
canonical_ids:
- name: person_id
merge_by_keys: [member_id, email]
merge_iterations: 3
do_not_merge_key: member_id
master_tables:
- name: master_table_ex4
canonical_id: person_id
attributes:
- name: member_id
source_columns:
- {table: site_aaa, priority: 1}
- name: email
source_columns:
- {table: site_aaa, priority: 1}
- name: tel
array_elements: 2
source_columns:
- {table: site_aaa, priority: 1}
- name: name
array_elements: 2
source_columns:
- {table: site_aaa, priority: 1}