ImportError:无法导入名称“firestore”

Question

我正在做一个数据流应用程序，它可以在firestore中编写，当我在DirectRunner上运行时它可以工作，但当我在DataflowRunner上运行时它不能工作。错误是什么？我的requirements.txt是：

apache-beam[gcp,test]==2.19.0
google-cloud-pubsub
google-cloud-firestore==0.29.0

抛出exeption的代码行是：

from google.cloud import firestore
db = firestore.Client(project=project)

Answer 1

在数据流常见问题解答中记录了这一点，有几种方法可以处理此问题

1. 在函数定义中使用import语句
2. 在管道选项中将save_main_session设置为True
3. 定义依赖项并使用requirements.txt和setup.py文件

<代码>G29适当地组织文件夹结构

更多详情请点击此处-- https://cloud.google.com/dataflow/docs/resources/faq#how_do_i_handle_nameerrors