这个管道的目标是了解Ptransform如何在Pubsub到Python管道中工作。我给出了以下输入,但它在输出pubsub中给出了相同的输入。这样做的目的是从pubsub的传入流中获取一个字段,然后只将该字段发送到输出主题。{"field_1":"14726485","field_2":"3947183"}
class ExtractStoreStock(beam.PTransform)
data = data.encode("utf-8")然后,我有一个Dataflow,它从附加到主题的订阅中读取,然后按如下方式计算管道的每个元素:import apache_beam as beam
from apache_beam.options.pipeline_options/subscriptions/YOUR-SUBSCRIPTION-N