次のように、mysql をバケットにダンプする単純な DAG を作成しようとしています。
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 で呼び出される MySQL 接続を作成します。
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 データベースにアクセスするための許可を composer に与えるには、何をする必要がありますか?