我正在运行 Python 数据流 wordcount_minimal.py 示例,并且工作正常。
无论如何,我现在正在尝试从 Flask 视图中创建一个管道,并且由于奇怪而一直失败:
ImportError: Cannot re-init internal module __main__
这是由dill
包提出的,更具体地说是:
https://github.com/uqfoundation/dill/blob/master/dill/dill.py#L67
我做了一些测试,比如创建全新的 virtualenv,以及创建一个没有其他依赖项的简单 Flask 应用程序;所有需要的软件包是:
Flask==0.11.1
google-cloud-dataflow
问题仍然存在。在 github 上的问题列表中没有发现任何东西,无论是在 Dataflow Python SDK 和 dill 包存储库中。