-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy path04_Bronze_To_Silver.py
99 lines (59 loc) · 1.92 KB
/
04_Bronze_To_Silver.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
# Databricks notebook source
# MAGIC %md
# MAGIC ### TRANSFERING DATA FROM BRONZE TO SILVER
# COMMAND ----------
# MAGIC %md
# MAGIC ### INCULDING DIFFERENT REQUIRED NOTEBOOKS
# COMMAND ----------
# MAGIC %md
# MAGIC Including Notebook Named **TableAndDataMappingConfigs**
# COMMAND ----------
# MAGIC %run "./customConfig/TableAndDataMappingConfigs"
# COMMAND ----------
# MAGIC %md
# MAGIC Including Notebook Named **0_DefaultTablesCreation**
# COMMAND ----------
# MAGIC %run "./0_DefaultTablesCreation"
# COMMAND ----------
# MAGIC %md
# MAGIC Including Notebook Named **01_CommonFunctions**
# COMMAND ----------
# MAGIC %run "./01_CommonFunctions"
# COMMAND ----------
# MAGIC %md
# MAGIC Including Notebook Named **03_TransformationView**
# COMMAND ----------
# MAGIC %run "./03_TransformationView"
# COMMAND ----------
# MAGIC %md
# MAGIC ### DOWNLOADING REQUIRED MODULES FOR THE ACTION
# COMMAND ----------
# MAGIC %sh
# MAGIC python -m pip install oracledb
# COMMAND ----------
# MAGIC %md
# MAGIC ### MERGING DATA FROM TRANSFORMATION VIEW TO SILVER
# COMMAND ----------
upsertBronzeToSilver(soureTable="intercambio_common_tranformation",targetTable=silverDataBase+"."+silverCommonTable,sourceMatchingCol="CHAVE_NOTA",targetMatchingCol="CHAVE_NOTA")
upsertBronzeToSilver("intercambio_item_transformation",silverDataBase+"."+silverItemTable,"CD_SERVICO","DT_ATENDIMENTO")
# COMMAND ----------
# MAGIC %md
# MAGIC ### CHECKING THE SILVER TABLES DATA AFTER IGESTION
# COMMAND ----------
# MAGIC %md
# MAGIC Selecting the Silver DataBase
# COMMAND ----------
# MAGIC %sql
# MAGIC use intercambiosilverdb;
# COMMAND ----------
# MAGIC %md
# MAGIC Fetching Data From Item Silver Table
# COMMAND ----------
# MAGIC %sql
# MAGIC select * from IntercambioItemSilver;
# COMMAND ----------
# MAGIC %md
# MAGIC Fetching Data From Common Silver Table
# COMMAND ----------
# MAGIC %sql
# MAGIC select * from IntercambioCommonSilver;