Problem We have never use PythonOperator in airflow and we want new joiner to understand how airflow works or how pythonoperator works.
Use case For loading csv data from Google Cloud Storage to Google Bigquery. For Exporting table from Google Bigquery to Google Cloud Storage (csv). For sending alert notification of job’s status to Slack.
Built With
- google-bigquery
- google-clound
- python


Log in or sign up for Devpost to join the conversation.