python --使用use_beam_bq_sink实验选项行为

z6psavjg  于 2023-02-21  发布在  Python
关注(0)|答案(1)|浏览(137)

我对Google Cloud部署中Apache Beam的选项解析有疑问。目前我的项目在部署时使用以下选项:--experiments use_beam_bq_sink.
但是,目前我们还需要启用runner_v2,它使用选项--experiments=use_runner_v2,该选项遵循不同的格式。
提前感谢您的帮助!
我尝试使用单独的--experiments标志启用这两个选项,将两个值设置为用空格分隔,然后再次用逗号分隔,这导致在执行时出现"unparseable"警告。

pod7payv

pod7payv1#

要解决您的问题,可以使用experiments--additional-experiments参数,例如:

python -m folder.main
 --experiments=use_runner_v2 \
 --additional-experiments=use_beam_bq_sink \
 ....

相关问题