我试图创建一个简单的dag,将mysql转储到一个bucket中,如下所示:
extract = MySqlToGoogleCloudStorageOperator(
task_id='extract_data',
mysql_conn_id='mysql_instance_connection',
google_cloud_storage_conn_id='google_cloud_storage_default',
sql='SELECT * FROM guestbook.entries',
bucket='gs://bucketname',
filename='guestbook.dump',
dag=dag)
我创建了一个名为 mysql_instance_connection
主机的ip地址,模式的数据库名称,在线创建数据库时设置的登录名和密码,端口为3306。
运行dag时,出现以下错误: _mysql_exceptions.OperationalError: (2003, "Can't connect to MySQL server on '[IP_ADDRESS]' (110)")@-@{"task-id": "extract_data", "execution-date": "2018-08-21T16:35:59.161183", "workflow": "extractMysqlData"}
我需要做什么才能授予composer访问mysql数据库的权限?
暂无答案!
目前还没有任何答案,快来回答吧!