Python Freelancers

My pubsub pull subscription is sending over the message and a None value for each message. I need t… Read more How To Filter None Values Out Of Pcollection

When I run Beam program i'm getting below error. 2021-05-20T17:04:42.166994441ZError message … Read more Attributeerror: '_dofnparam' Object Has No Attribute 'start' [while Running 'write To Gcs-ptransform-146']

I have a simple Google DataFlow task. It reads from a BigQuery table and writes into another, just … Read more Bigquery Dataflow Error: Cannot Read And Write In Different Locations While Reading And Writing In Eu

Can someone clarify what's the purpose for id_label argument in ReafFromPubSub transform? I'… Read more Beam / Dataflow ::readfrompubsub(id_label) :: Unexpected Behavior

Running a DataFlow streaming job using 2.11.0 release. I get the following authentication error af… Read more Google Cloud Dataflow Job Throws Alert After Few Hours

I've developed an apache beam pipeline locally where I run predictions on a sample file. Locall… Read more How To Load My Pickeled Ml Model From Gcs To Dataflow/apache Beam

Here's the situation: I have a set of files in GCS that are compressed and have a .gz file exte… Read more Dataflow Gcs To Bq Problems

I can't create a custom Google Cloud Dataflow template using the wordcount example following th… Read more How To Create Google Cloud Dataflow Wordcount Custom Template In Python?