云编写器：如何在Airflow中删除目标Cloud SQL表？

问题描述

我正在创建DAG，以将一些数据从Big Query导入Cloud sql 一切正常，但我需要删除Cloud sql目标表

我的功能就是这样

def executeCSVImport(table_name_import):
credentials = GoogleCredentials.get_application_default()
service = discovery.build('sqladmin','v1beta4',credentials=credentials)

# Project ID of the project that contains the instance.
project_cloud = 'myproject-19828347233'


instance = CONF.sql_DATABASE

instances_import_request_body = {
    "importContext": {
        "kind": "sql#importContext","fileType": "CSV","uri": "gs://test/" + CONF.CLOUD_sql_PROJECT + "_Dashboards_views.csv","database": instance,"csvImportOptions": {
            "table": table_name_import,}
    }
}

request = service.instances().import_(project=project_cloud,instance=instance,body=instances_import_request_body)
response = request.execute()
logging.info(response)
return True

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）