我需要
1. run a select query on MYSQL DB and fetch the records.
2. Records are processed by python script.
我不确定该怎么做.xcom是go 这里的路吗？此外，MYSQLOperator只执行查询，不获取记录.有没有我可以使用的内置传输操作符？我如何在这里使用MYSQL钩子？
你可能想使用一个PythonOperator，它使用钩子来获取数据，
有人能解释一下如何处理同样的问题吗.
Refer - 100
def do_work():
mysqlserver = MySqlHook(connection_id)
sql = "SELECT * from table where col > 100 "
row_count = mysqlserver.get_records(sql, schema='testdb')
print row_count[0][0]
callMYSQLHook = PythonOperator(
task_id='fetch_from_testdb',
python_callable=mysqlHook,
dag=dag
)
这是正确的方法吗？
t = MySqlOperator(
conn_id='mysql_default',
task_id='basic_mysql',
sql="SELECT count(*) from table1 where id > 10",
dag=dag)