0

次のように、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 に与えるには、何をする必要がありますか?

4

0 に答える 0