2017-11-06 17 views
0

私はGoogleのデータフロー上で実行されているapacheのビームパイプラインからgoogle cloud sql postgresのインスタンスに接続したいと思います。
私はこれをPython SDKを使用して行いたいと思います。
私はこれに関する適切な文書を見つけることができません。
クラウドSQLのガイド方法データフローのドキュメントはありません。
https://cloud.google.com/sql/docs/postgres/GoogleのクラウドをSQLパイプラインからSQLポストグルインスタンスに接続

ドキュメントリンク/ githubの例を提供できますか?

答えて

0

Java SDKには、標準のJava JDBCメカニズムを介してアクセスできる任意のデータベースに接続できるJdbcIOが含まれています。現在、Beam Python SDKにはアナログはありません。もしあれば、Python DB-APIを使用していると思います。 (例えば、JavaのJdbcIOのソースコードを模倣することにより)発展することはかなり簡単ですが、非常に便利な:)

+0

私は、Java SDKを使用して接続しようとしています @jkffおかげ - a feature requestをファイルまたは貢献してお気軽に。 私は、プロキシとローカルでpiplineを使用してpostgresインスタンスに接続できます。 しかし、データ・フローにデプロイした後、ビーム・パイプラインがクラウドSQL Postgresに直接接続できる方法はありますか。 https://cloud.google.com/appengine/docs/flexible/java/using-cloud-sql-postgres に記載されている手順を実行しようとしましたが、Googleに不明なホストを提供しています。 データフローをpostgres cloud sqlに接続するためのドキュメントを教えてください。 – s28

+0

ローカルで動作する同じパイプラインを使用してデータフロー上で実行しようとすると、何がうまくいかないかという詳細を新しい質問に投稿できますか? – jkff

関連する問題