【发布时间】:2020-11-04 23:16:35
【问题描述】:
我正在尝试在 DataFlow 上创建一个需要 Cloud SQL 连接的 Python 作业(我完全是初学者)。我需要在 ParDo (Apache Beam) 中执行几个 MySQL 查询。我正在使用 PyMySQL 并且有身份验证问题,所以我尝试了 this 答案,显然它有效:
class MyDoFn(beam.DoFn):
def setup(self):
os.system("wget https://dl.google.com/cloudsql/cloud_sql_proxy.linux.amd64 -O cloud_sql_proxy")
os.system("chmod +x cloud_sql_proxy")
os.system(f"./cloud_sql_proxy -instances={self.sql_args['cloud_sql_connection_name']}=tcp:3306 &")
问题是,我发现这更像是一种变通方法。以这种方式进行身份验证是否安全?我将不胜感激任何帮助!提前谢谢你。
【问题讨论】:
标签: mysql python-3.x proxy google-cloud-dataflow apache-beam