Airflowを使ってBQから取得した値をPythonでprintしたいのですが上手くいきません。
下記の書き方でおかしい点の検討もつかず、アドバイスをいただけますでしょうか・・・・?
python
1 2bq_getdata = BigQueryGetDataOperator( 3 task_id = 'bq_getdata', 4 dataset_id = 'xxxx', 5 table_id ='xxxx', 6 max_result='1', 7 selected= 'date', 8 bigquery_conn_id='google_cloud_default', 9 xcom_Push=True, 10 dag = dag, 11 ) 12 13def getdatas (**context): 14 bq_data = context['task_instance'].xcom_pull(task_ids='bq_getdata') 15 print(bq_data)
あなたの回答
tips
プレビュー