SAP_ZRFS009

封裝概述

建立時間：11/1/2018 10:31:15 AM
產品版本：14.0.3008.28
Version Build：310
Connection 數：1
控制流任務數：97
Data Flow 數：0

封裝清單

任務名稱	類型	SQL
delete 1D	Microsoft.ExecuteSQLTask	delete [sapbms].[dbo].[SAP_ZRFS009_1D] where DTLDATE = ?
delete 1S	Microsoft.ExecuteSQLTask	delete [sapbms].[dbo].[SAP_ZRFS009_1S] where DTLDATE = ?
delete 2D	Microsoft.ExecuteSQLTask	delete [sapbms].[dbo].[SAP_ZRFS009_2D] where DTLDATE = ?
delete 2S	Microsoft.ExecuteSQLTask	delete [sapbms].[dbo].[SAP_ZRFS009_2S] where DTLDATE = ?
GET DATE	Microsoft.ExecuteSQLTask	select CONVERT(char(8), getdate(), 112) , CONVERT(char(8), getdate(), 112)
INSERT End Log	Microsoft.ExecuteSQLTask	exec dbo.SP_SYS_PG_Log 'BMS',?,?,'N'
INSERT Start Log	Microsoft.ExecuteSQLTask	exec dbo.SP_SYS_PG_Log 'BMS',?,?,'Y'
make file 41120200	STOCK:SEQUENCE
GET target1 1D	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0041120200-'+?+'-1D.txt'
GET target1 1S	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0041120200-'+?+'-1S.txt'
GET target1 2D	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0041120200-'+?+'-2D.txt'
GET target1 2S	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0041120200-'+?+'-2S.txt'
檔案系統工作	Microsoft.FileSystemTask
檔案系統工作 1	Microsoft.FileSystemTask
檔案系統工作 2	Microsoft.FileSystemTask
檔案系統工作 3	Microsoft.FileSystemTask
make file 41122900	STOCK:SEQUENCE
GET target2 1D	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0041122900-'+?+'-1D.txt'
GET target2 1S	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0041122900-'+?+'-1S.txt'
GET target2 2D	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0041122900-'+?+'-2D.txt'
GET target2 2S	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0041122900-'+?+'-2S.txt'
檔案系統工作 4	Microsoft.FileSystemTask
檔案系統工作 5	Microsoft.FileSystemTask
檔案系統工作 6	Microsoft.FileSystemTask
檔案系統工作 7	Microsoft.FileSystemTask
make file 41123600	STOCK:SEQUENCE
GET target3 1D	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0041123600-'+?+'-1D.txt'
GET target3 1S	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0041123600-'+?+'-1S.txt'
GET target3 2D	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0041123600-'+?+'-2D.txt'
GET target3 2S	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0041123600-'+?+'-2S.txt'
檔案系統工作 10	Microsoft.FileSystemTask
檔案系統工作 11	Microsoft.FileSystemTask
檔案系統工作 8	Microsoft.FileSystemTask
檔案系統工作 9	Microsoft.FileSystemTask
make file 53030000	STOCK:SEQUENCE
GET target4 1D	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0053030000-'+?+'-1D.txt'
GET target4 1S	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0053030000-'+?+'-1S.txt'
GET target4 2D	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0053030000-'+?+'-2D.txt'
GET target4 2S	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0053030000-'+?+'-2S.txt'
檔案系統工作 12	Microsoft.FileSystemTask
檔案系統工作 13	Microsoft.FileSystemTask
檔案系統工作 14	Microsoft.FileSystemTask
檔案系統工作 15	Microsoft.FileSystemTask
make file 53040000	STOCK:SEQUENCE
GET target5 1D	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0053040000-'+?+'-1D.txt'
GET target5 1S	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0053040000-'+?+'-1S.txt'
GET target5 2D	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0053040000-'+?+'-2D.txt'
GET target5 2S	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0053040000-'+?+'-2S.txt'
檔案系統工作 16	Microsoft.FileSystemTask
檔案系統工作 17	Microsoft.FileSystemTask
檔案系統工作 18	Microsoft.FileSystemTask
檔案系統工作 19	Microsoft.FileSystemTask
make file 53050000	STOCK:SEQUENCE
GET target6 1D	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0053050000-'+?+'-1D.txt'
GET target6 1S	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0053050000-'+?+'-1S.txt'
GET target6 2D	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0053050000-'+?+'-2D.txt'
GET target6 2S	Microsoft.ExecuteSQLTask	select 'F:\bigdata\SAP\0053050000-'+?+'-2S.txt'
檔案系統工作 20	Microsoft.FileSystemTask
檔案系統工作 21	Microsoft.FileSystemTask
檔案系統工作 22	Microsoft.FileSystemTask
檔案系統工作 23	Microsoft.FileSystemTask
rum 41120200	STOCK:SEQUENCE
執行封裝工作	Microsoft.ExecutePackageTask
執行封裝工作 1	Microsoft.ExecutePackageTask
執行封裝工作 2	Microsoft.ExecutePackageTask
執行封裝工作 3	Microsoft.ExecutePackageTask
rum 41122900	STOCK:SEQUENCE
執行封裝工作	Microsoft.ExecutePackageTask
執行封裝工作 1	Microsoft.ExecutePackageTask
執行封裝工作 2	Microsoft.ExecutePackageTask
執行封裝工作 3	Microsoft.ExecutePackageTask
rum 41123600	STOCK:SEQUENCE
執行封裝工作	Microsoft.ExecutePackageTask
執行封裝工作 1	Microsoft.ExecutePackageTask
執行封裝工作 2	Microsoft.ExecutePackageTask
執行封裝工作 3	Microsoft.ExecutePackageTask
rum 53030000	STOCK:SEQUENCE
執行封裝工作	Microsoft.ExecutePackageTask
執行封裝工作 1	Microsoft.ExecutePackageTask
執行封裝工作 2	Microsoft.ExecutePackageTask
執行封裝工作 3	Microsoft.ExecutePackageTask
rum 53040000	STOCK:SEQUENCE
執行封裝工作	Microsoft.ExecutePackageTask
執行封裝工作 1	Microsoft.ExecutePackageTask
執行封裝工作 2	Microsoft.ExecutePackageTask
執行封裝工作 3	Microsoft.ExecutePackageTask
rum 53050000	STOCK:SEQUENCE
執行封裝工作	Microsoft.ExecutePackageTask
執行封裝工作 1	Microsoft.ExecutePackageTask
執行封裝工作 2	Microsoft.ExecutePackageTask
執行封裝工作 3	Microsoft.ExecutePackageTask
UNION 1D	Microsoft.ExecuteSQLTask	insert into [sapbms].[dbo].[SAP_ZRFS009_1D] select *,convert (varchar(6), da...
UNION 1S	Microsoft.ExecuteSQLTask	insert into [sapbms].[dbo].[SAP_ZRFS009_1S] select *,convert (varchar(6), da...
UNION 2D	Microsoft.ExecuteSQLTask	insert into [sapbms].[dbo].[SAP_ZRFS009_2D] select *,convert (varchar(6), da...
UNION 2S	Microsoft.ExecuteSQLTask	insert into [sapbms].[dbo].[SAP_ZRFS009_2S] select *,convert (varchar(6), da...
zipfile	Microsoft.ExecuteSQLTask	select 'F:\ftp_root\LocalUser\sap_bda\'+CONVERT(char(6),DATEADD(month,0,getda...
解壓縮zip檔	Microsoft.ExecuteProcess

Connection 清單

名稱	Creation Name	Connection String
ZWP207-10_ACCGRP_LEAF	FLATFILE	F:\Themis\SAP_TEST_DATA\_ZWP207-10_ACCGRP_LEAF.CSV

控制流

flowchart LR
    檔案系統工作_2["檔案系統工作 2"] --> GET_target1_2S["GET target1 2S"]
    GET_target1_1D["GET target1 1D"] --> 檔案系統工作["檔案系統工作"]
    GET_target1_1S["GET target1 1S"] --> 檔案系統工作_1["檔案系統工作 1"]
    GET_target1_2D["GET target1 2D"] --> 檔案系統工作_2["檔案系統工作 2"]
    GET_target1_2S["GET target1 2S"] --> 檔案系統工作_3["檔案系統工作 3"]
    檔案系統工作["檔案系統工作"] --> GET_target1_1S["GET target1 1S"]
    檔案系統工作_1["檔案系統工作 1"] --> GET_target1_2D["GET target1 2D"]
    檔案系統工作_4["檔案系統工作 4"] --> GET_target2_1S["GET target2 1S"]
    檔案系統工作_5["檔案系統工作 5"] --> GET_target2_2D["GET target2 2D"]
    檔案系統工作_6["檔案系統工作 6"] --> GET_target2_2S["GET target2 2S"]
    GET_target2_1S["GET target2 1S"] --> 檔案系統工作_5["檔案系統工作 5"]
    GET_target2_2D["GET target2 2D"] --> 檔案系統工作_6["檔案系統工作 6"]
    GET_target2_2S["GET target2 2S"] --> 檔案系統工作_7["檔案系統工作 7"]
    GET_target2_1D["GET target2 1D"] --> 檔案系統工作_4["檔案系統工作 4"]
    GET_target3_1D["GET target3 1D"] --> 檔案系統工作_8["檔案系統工作 8"]
    GET_target3_1S["GET target3 1S"] --> 檔案系統工作_9["檔案系統工作 9"]
    GET_target3_2D["GET target3 2D"] --> 檔案系統工作_10["檔案系統工作 10"]
    GET_target3_2S["GET target3 2S"] --> 檔案系統工作_11["檔案系統工作 11"]
    檔案系統工作_8["檔案系統工作 8"] --> GET_target3_1S["GET target3 1S"]
    檔案系統工作_9["檔案系統工作 9"] --> GET_target3_2D["GET target3 2D"]
    檔案系統工作_10["檔案系統工作 10"] --> GET_target3_2S["GET target3 2S"]
    GET_target4_1D["GET target4 1D"] --> 檔案系統工作_12["檔案系統工作 12"]
    GET_target4_1S["GET target4 1S"] --> 檔案系統工作_13["檔案系統工作 13"]
    GET_target4_2D["GET target4 2D"] --> 檔案系統工作_14["檔案系統工作 14"]
    GET_target4_2S["GET target4 2S"] --> 檔案系統工作_15["檔案系統工作 15"]
    檔案系統工作_12["檔案系統工作 12"] --> GET_target4_1S["GET target4 1S"]
    檔案系統工作_13["檔案系統工作 13"] --> GET_target4_2D["GET target4 2D"]
    檔案系統工作_14["檔案系統工作 14"] --> GET_target4_2S["GET target4 2S"]
    GET_target5_1D["GET target5 1D"] --> 檔案系統工作_16["檔案系統工作 16"]
    GET_target5_1S["GET target5 1S"] --> 檔案系統工作_17["檔案系統工作 17"]
    GET_target5_2D["GET target5 2D"] --> 檔案系統工作_18["檔案系統工作 18"]
    GET_target5_2S["GET target5 2S"] --> 檔案系統工作_19["檔案系統工作 19"]
    檔案系統工作_16["檔案系統工作 16"] --> GET_target5_1S["GET target5 1S"]
    檔案系統工作_17["檔案系統工作 17"] --> GET_target5_2D["GET target5 2D"]
    檔案系統工作_18["檔案系統工作 18"] --> GET_target5_2S["GET target5 2S"]
    GET_target6_1D["GET target6 1D"] --> 檔案系統工作_20["檔案系統工作 20"]
    檔案系統工作_20["檔案系統工作 20"] --> GET_target6_1S["GET target6 1S"]
    GET_target6_1S["GET target6 1S"] --> 檔案系統工作_21["檔案系統工作 21"]
    GET_target6_2D["GET target6 2D"] --> 檔案系統工作_22["檔案系統工作 22"]
    GET_target6_2S["GET target6 2S"] --> 檔案系統工作_23["檔案系統工作 23"]
    檔案系統工作_21["檔案系統工作 21"] --> GET_target6_2D["GET target6 2D"]
    檔案系統工作_22["檔案系統工作 22"] --> GET_target6_2S["GET target6 2S"]
    執行封裝工作["執行封裝工作"] --> 執行封裝工作_1["執行封裝工作 1"]
    執行封裝工作_1["執行封裝工作 1"] --> 執行封裝工作_2["執行封裝工作 2"]
    執行封裝工作_2["執行封裝工作 2"] --> 執行封裝工作_3["執行封裝工作 3"]
    執行封裝工作["執行封裝工作"] --> 執行封裝工作_1["執行封裝工作 1"]
    執行封裝工作_1["執行封裝工作 1"] --> 執行封裝工作_2["執行封裝工作 2"]
    執行封裝工作_2["執行封裝工作 2"] --> 執行封裝工作_3["執行封裝工作 3"]
    執行封裝工作["執行封裝工作"] --> 執行封裝工作_1["執行封裝工作 1"]
    執行封裝工作_1["執行封裝工作 1"] --> 執行封裝工作_2["執行封裝工作 2"]
    執行封裝工作_2["執行封裝工作 2"] --> 執行封裝工作_3["執行封裝工作 3"]
    執行封裝工作["執行封裝工作"] --> 執行封裝工作_1["執行封裝工作 1"]
    執行封裝工作_1["執行封裝工作 1"] --> 執行封裝工作_2["執行封裝工作 2"]
    執行封裝工作_2["執行封裝工作 2"] --> 執行封裝工作_3["執行封裝工作 3"]
    執行封裝工作["執行封裝工作"] --> 執行封裝工作_1["執行封裝工作 1"]
    執行封裝工作_1["執行封裝工作 1"] --> 執行封裝工作_2["執行封裝工作 2"]
    執行封裝工作_2["執行封裝工作 2"] --> 執行封裝工作_3["執行封裝工作 3"]
    執行封裝工作["執行封裝工作"] --> 執行封裝工作_1["執行封裝工作 1"]
    執行封裝工作_1["執行封裝工作 1"] --> 執行封裝工作_2["執行封裝工作 2"]
    執行封裝工作_2["執行封裝工作 2"] --> 執行封裝工作_3["執行封裝工作 3"]
    INSERT_Start_Log["INSERT Start Log"] --> GET_DATE["GET DATE"]
    delete_1S["delete 1S"] --> UNION_1S["UNION 1S"]
    make_file_53030000["make file 53030000"] --> make_file_53040000["make file 53040000"]
    make_file_53040000["make file 53040000"] --> make_file_53050000["make file 53050000"]
    make_file_53050000["make file 53050000"] --> zipfile["zipfile"]
    zipfile["zipfile"] --> 解壓縮zip檔["解壓縮zip檔"]
    解壓縮zip檔["解壓縮zip檔"] --> rum_41120200["rum 41120200"]
    rum_41120200["rum 41120200"] --> rum_41122900["rum 41122900"]
    rum_41122900["rum 41122900"] --> rum_41123600["rum 41123600"]
    rum_41123600["rum 41123600"] --> rum_53030000["rum 53030000"]
    rum_53030000["rum 53030000"] --> rum_53040000["rum 53040000"]
    rum_53040000["rum 53040000"] --> rum_53050000["rum 53050000"]
    UNION_2D["UNION 2D"] --> delete_2S["delete 2S"]
    rum_53050000["rum 53050000"] --> delete_1D["delete 1D"]
    UNION_1D["UNION 1D"] --> delete_1S["delete 1S"]
    UNION_1S["UNION 1S"] --> delete_2D["delete 2D"]
    delete_2S["delete 2S"] --> UNION_2S["UNION 2S"]
    UNION_2S["UNION 2S"] --> INSERT_End_Log["INSERT End Log"]
    delete_1D["delete 1D"] --> UNION_1D["UNION 1D"]
    delete_2D["delete 2D"] --> UNION_2D["UNION 2D"]
    GET_DATE["GET DATE"] --> make_file_41120200["make file 41120200"]
    make_file_41120200["make file 41120200"] --> make_file_41122900["make file 41122900"]
    make_file_41122900["make file 41122900"] --> make_file_41123600["make file 41123600"]
    make_file_41123600["make file 41123600"] --> make_file_53030000["make file 53030000"]

資料流架構

此封裝無 Data Flow

GCP 轉換說明

涉及服務：Dataform, Managed Airflow, Cloud Storage, Cloud Run

來源元件	對應 GCP 服務	說明
delete 1D	Dataform	operations / scheduled SQL
delete 1S	Dataform	operations / scheduled SQL
delete 2D	Dataform	operations / scheduled SQL
delete 2S	Dataform	operations / scheduled SQL
GET DATE	Dataform	operations / scheduled SQL
INSERT End Log	Dataform	operations / scheduled SQL
INSERT Start Log	Dataform	operations / scheduled SQL
make file 41120200	Managed Airflow	TaskGroup
GET target1 1D	Dataform	operations / scheduled SQL
GET target1 1S	Dataform	operations / scheduled SQL
GET target1 2D	Dataform	operations / scheduled SQL
GET target1 2S	Dataform	operations / scheduled SQL
檔案系統工作	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 1	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 2	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 3	Cloud Storage	GCS 物件操作 (Cloud Run step)
make file 41122900	Managed Airflow	TaskGroup
GET target2 1D	Dataform	operations / scheduled SQL
GET target2 1S	Dataform	operations / scheduled SQL
GET target2 2D	Dataform	operations / scheduled SQL
GET target2 2S	Dataform	operations / scheduled SQL
檔案系統工作 4	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 5	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 6	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 7	Cloud Storage	GCS 物件操作 (Cloud Run step)
make file 41123600	Managed Airflow	TaskGroup
GET target3 1D	Dataform	operations / scheduled SQL
GET target3 1S	Dataform	operations / scheduled SQL
GET target3 2D	Dataform	operations / scheduled SQL
GET target3 2S	Dataform	operations / scheduled SQL
檔案系統工作 10	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 11	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 8	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 9	Cloud Storage	GCS 物件操作 (Cloud Run step)
make file 53030000	Managed Airflow	TaskGroup
GET target4 1D	Dataform	operations / scheduled SQL
GET target4 1S	Dataform	operations / scheduled SQL
GET target4 2D	Dataform	operations / scheduled SQL
GET target4 2S	Dataform	operations / scheduled SQL
檔案系統工作 12	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 13	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 14	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 15	Cloud Storage	GCS 物件操作 (Cloud Run step)
make file 53040000	Managed Airflow	TaskGroup
GET target5 1D	Dataform	operations / scheduled SQL
GET target5 1S	Dataform	operations / scheduled SQL
GET target5 2D	Dataform	operations / scheduled SQL
GET target5 2S	Dataform	operations / scheduled SQL
檔案系統工作 16	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 17	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 18	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 19	Cloud Storage	GCS 物件操作 (Cloud Run step)
make file 53050000	Managed Airflow	TaskGroup
GET target6 1D	Dataform	operations / scheduled SQL
GET target6 1S	Dataform	operations / scheduled SQL
GET target6 2D	Dataform	operations / scheduled SQL
GET target6 2S	Dataform	operations / scheduled SQL
檔案系統工作 20	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 21	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 22	Cloud Storage	GCS 物件操作 (Cloud Run step)
檔案系統工作 23	Cloud Storage	GCS 物件操作 (Cloud Run step)
rum 41120200	Managed Airflow	TaskGroup
執行封裝工作	Managed Airflow	子 DAG / TriggerDagRun
執行封裝工作 1	Managed Airflow	子 DAG / TriggerDagRun
執行封裝工作 2	Managed Airflow	子 DAG / TriggerDagRun
執行封裝工作 3	Managed Airflow	子 DAG / TriggerDagRun
rum 41122900	Managed Airflow	TaskGroup
rum 41123600	Managed Airflow	TaskGroup
rum 53030000	Managed Airflow	TaskGroup
rum 53040000	Managed Airflow	TaskGroup
rum 53050000	Managed Airflow	TaskGroup
UNION 1D	Dataform	operations / scheduled SQL
UNION 1S	Dataform	operations / scheduled SQL
UNION 2D	Dataform	operations / scheduled SQL
UNION 2S	Dataform	operations / scheduled SQL
zipfile	Dataform	operations / scheduled SQL
解壓縮zip檔	Cloud Run	容器化外部程序

選擇左側封裝查看詳情