使用 Google 云数据流从一个数据存储读取数据并写入另一个数据存储

Reading data from one datastore and writing to another, with Google cloud dataflow

我正在尝试处理来自一个数据存储(来自项目 A)的一些数据,并将其写入另一个数据存储(在项目 B 中)。我的运行失败,出现异常 -

 com.google.datastore.v1.client.DatastoreException: mismatched databases within request: <unknown!>~projecta vs. <unknown!>~projectb, code=INVALID_ARGUMENT

难道不能从云数据流做这样的事情吗?

我真的无法从一个错误中判断出你做了什么,但你可能试图将查询中的实体从一个数据存储实例保存到另一个数据存储实例。问题是数据存储实例 ID 嵌入在每个键中。因此(作为起点)您可能应该使用查询结果中的属性创建新的实体对象并保存它们。