You are viewing a plain text version of this content. The canonical link for it is here.
Posted to github@beam.apache.org by GitBox <gi...@apache.org> on 2022/06/04 18:11:09 UTC

[GitHub] [beam] damccorm opened a new issue, #20564: AttributeError: 'SubscriberClient' object has no attribute 'transport' error while reading from input subscription with ReadFromPubSub

damccorm opened a new issue, #20564:
URL: https://github.com/apache/beam/issues/20564

   When I read from the input-subcroption with beam.io.ReadFromPubSub. The error below is thrown.
   >  AttributeError: 'SubscriberClient' object has no attribute 'transport'
   >  
   
   Code
   
   `pipeline_options = PipelineOptions()`
   `pipeline_options.view_as(StandardOptions).streaming = True`
   
   `pipeline = beam.Pipeline(options=pipeline_options)`
   `messages = (pipeline | beam.io.ReadFromPubSub(subscription=input_subscription).with_output_types(bytes))`
   
   `def printattr(element):`
   ` print(element.attributes)`
   
   
   `lines = messages | 'printattr' >> beam.Map(printattr)`
   
   `result = pipeline.run()`
   `result.wait_until_finish()`
   
   Imported from Jira [BEAM-11318](https://issues.apache.org/jira/browse/BEAM-11318). Original Jira may contain additional context.
   Reported by: celine.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [beam] tvalentyn closed issue #20564: AttributeError: 'SubscriberClient' object has no attribute 'transport' error while reading from input subscription with ReadFromPubSub

Posted by GitBox <gi...@apache.org>.
tvalentyn closed issue #20564: AttributeError: 'SubscriberClient' object has no attribute 'transport' error while reading from input subscription with ReadFromPubSub
URL: https://github.com/apache/beam/issues/20564


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [beam] kennknowles commented on issue #20564: AttributeError: 'SubscriberClient' object has no attribute 'transport' error while reading from input subscription with ReadFromPubSub

Posted by GitBox <gi...@apache.org>.
kennknowles commented on issue #20564:
URL: https://github.com/apache/beam/issues/20564#issuecomment-1334724784

   @johnjcasey @tvalentyn this should be easy to validate or not; I assume reading from Pubsub does work with Python, but is there a corner case? it probably changed a lot since this issue


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [beam] tvalentyn commented on issue #20564: AttributeError: 'SubscriberClient' object has no attribute 'transport' error while reading from input subscription with ReadFromPubSub

Posted by GitBox <gi...@apache.org>.
tvalentyn commented on issue #20564:
URL: https://github.com/apache/beam/issues/20564#issuecomment-1335975059

   Please reopen if you still the issue and provide a complete example. The above example wouldn't work since the pubsub message is not properly decoded, see example in https://github.com/apache/beam/blob/ec91ea4f6b83e6a8e3bd2041057fa90d0c8f0dd0/sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline/main.py#L108


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org