GoogleCloudPlatform/DataflowPythonSDK

Pubsub Source

dovy opened this issue · 8 comments

dovy commented

Can I use pubsub yet? I know we don't have "streaming", but I thought that was waiting after a pubsub topic was empty.

I need to use pubsub as my source, or put a router in front, or I can't even use Dataflow yet. :(

Not going to use Java over here...

This is currently not supported as an SDK primitive but is on our roadmap. You can, however, shell out to the gcloud PubSub CLI in a ParDo and send messages that way. When you run commands this way, API calls will execute as your GCP project's Compute Engine service account. This way, you can publish messages through this CLI tool. This workaround should work, but it isn't officially supported.

dovy commented

Care to provide any examples? I'd love to implement this asap. :)

dovy commented

My bad, I meant the reverse way. I want to process pubsub as a source... Have to get my terminology down.

Ah. No, sorry, this functionality isn't available yet, and is on our streaming roadmap.

dovy commented

Any form of an ETA? heh.

Sorry, I can't provide one here.

dovy commented

Email? Slack? ;). Dovy@owletcare.com