All Questions
2 questions
1
vote
1
answer
1k
views
Cloud Composer, "Lost connection to MySQL server at 'reading initial communication packet', system error: 0"
I'm running the Cloud Composer environment with Composer version 1.18.7 and Airflow version 1.10.15. Based on Google Cloud Platforms documentation the error message "(_mysql_exceptions....
0
votes
2
answers
4k
views
Airflow : pass parameter from python function to MySQL Operator
What I want to do :
- compare missing ID from MySQL and BigQuery
- get all data from MySQL where id in missing ID
table = 'orders'
def get_missing_ids():
aws_id = get_aws_id(table)
bq_id = ...
- 171