BigQueryIO.write操作成功/失败

有什么方法可以知道程序中BigQueryIO.write（）操作是否已成功完成？它返回WriteResult，但在其中找不到任何相关的方法。或者在那里？BigQueryIO.write操作成功/失败

2017-10-09 rish0097

如果管道中的任何操作失败，则重试该操作。如果重复失败，批处理作业将终止并标记为失败，并且流作业将继续重试。 WriteResult允许您使用InsertRetryPolicy来控制重试错误的方式。这允许IO部分成功并指示哪些行有问题。如果您未设置InsertRetryPolicy，则完成的管道意味着写入已成功完成。

如果这不能解决您的疑虑，您能详细说明您正在尝试做什么吗？

来源

2017-10-09 16:37:51

其实我有一个模板，我需要在数据写入BigQuery之后执行某些操作。但是，我在p.run（）方法之后编写的任何内容都不会执行（如果我仅使用Dataflow Runner而不是模板）。所以想到在BigQueryIO.write（）之后执行这些步骤。这可能吗？ – rish0097

我在WriteResult中看不到任何方法为insertRetryPolicy（）。这是梁2.2的东西吗？ – rish0097

InsertRetryPolicy是BigQuery写入的一个属性。如果一切成功，WriteResult将为空。 –

BigQueryIO.write操作成功/失败

回答

相关问题