相关疑难解决方法(0)

从python + flask + gunicorn + nginx + Compute Engine应用程序中读取从Google Cloud Storage下载的文件失败.链接到代码:https://github.com/samuq/CE-test.文件'ETL_SHP_READ_SQL_WRITE'的第64行没有返回任何内容,尽管该文件有效并且其中包含数据:

prj_blob.download_to_file(self.prj_file)
logger.log_text(self.prj_file)
line 64 -->       euref_fin.ImportFromWkt(self.prj_file.read())).

我有一个P1包含 ID 字段的PCollection 。我想从 PCollection 中获取完整的 ID 列作为列表，并将此值传递给 BigQuery 查询以过滤一个 BigQuery 表。

这样做的最快和最优化的方法是什么？

我是 Dataflow 和 BigData 的新手。任何人都可以对此提供一些提示吗？

谢谢！