-
Create Cloud Composer environment
-
Create a Cloud Storage bucket
-
Defining the workflow
-
Uploading DAG to cloud storage
gsutil cp spark_dibimbing.py <DAGs_folder_path>
-
We use public data and copy to your Cloud Storage bucket
public data to your Cloud Storage bucket
-
The result is word count DAG and save to CSV