Apache Beam Python WriteToBigtable 可能到 Deadletter?

Apache Beam Python WriteToBigtable Possible to Deadletter?

正如标题所说,

当 WriteToBigtable() 失败时,是否可以在 pubsub 中写入死信主题?我知道它可能与 Bigquery 但在 BigTable 上没有看到任何东西。

我正在使用 Apache Beam python 库。

当前的 WriteToBigTable 没有 return 失败的记录。但是,您可以根据您的要求将自定义 PTransform 写入 return 失败的突变。 内置转换使用 google python 下面的客户端库写入大 table。您可以利用它的源代码并添加异常处理来输出您的异常类型。

源代码:https://beam.apache.org/releases/pydoc/2.25.0/_modules/apache_beam/io/gcp/bigtableio.html#WriteToBigTable