-
Notifications
You must be signed in to change notification settings - Fork 0
/
customer_landing_to_trusted.py
47 lines (42 loc) · 1.37 KB
/
customer_landing_to_trusted.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
import sys
from awsglue.transforms import *
from awsglue.utils import getResolvedOptions
from pyspark.context import SparkContext
from awsglue.context import GlueContext
from awsglue.job import Job
import re
args = getResolvedOptions(sys.argv, ["JOB_NAME"])
sc = SparkContext()
glueContext = GlueContext(sc)
spark = glueContext.spark_session
job = Job(glueContext)
job.init(args["JOB_NAME"], args)
# Script generated for node S3 bucket
S3bucket_node1 = glueContext.create_dynamic_frame.from_options(
format_options={"multiline": False},
connection_type="s3",
format="json",
connection_options={
"paths": ["s3://stedi-lakehouse/project/customer/landing/"],
"recurse": True,
},
transformation_ctx="S3bucket_node1",
)
# Script generated for node PrivacyFilter
PrivacyFilter_node1684510659304 = Filter.apply(
frame=S3bucket_node1,
f=lambda row: (not (row["shareWithResearchAsOfDate"] == 0)),
transformation_ctx="PrivacyFilter_node1684510659304",
)
# Script generated for node TrustedCustomerZone
TrustedCustomerZone_node3 = glueContext.write_dynamic_frame.from_options(
frame=PrivacyFilter_node1684510659304,
connection_type="s3",
format="json",
connection_options={
"path": "s3://stedi-lakehouse/project/customer/trusted/",
"partitionKeys": [],
},
transformation_ctx="TrustedCustomerZone_node3",
)
job.commit()