我正在尝试创建一个简单的 dag,将 mysql 转储到这样的存储桶中:
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 连接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"}
我需要做什么才能授予作曲家访问我的 MySQL 数据库的权限?