apachebeam/D中跨越多个文件的流水线代码

Question

经过长时间的搜索，我还没有找到一个跨越多个文件的数据流/束流管道的示例。Beam文档执行suggest a file structure（在“多个文件依赖项”部分下），但是它们给出的Juliaset示例实际上是a single code/source文件（以及调用它的main file）。基于Juliaset示例，我需要一个类似的文件结构：

juliaset/__init__.py
juliaset/juliaset.py # actual code
juliaset/some_conf.py
__init__.py
juliaset_main.py
setup.py

现在我想从juliaset/juliaset.py得到import .some_conf，它在本地运行时工作，但在数据流上运行时会出错

^{pr2}$

一个完整的工作例子将不胜感激！在

Answer 1

您能验证您的setup.py是否包含以下结构：

import setuptools

setuptools.setup(
    name='My Project',
    version='1.0',
    install_requires=[],
    packages=setuptools.find_packages(),
)

导入模块，如from juliaset.juliaset import SomeClass

当您调用Python脚本时，使用python -m juliaset_main（不带.py）

不知道你是否已经试过了，只是为了确定一下。在