Hi, i have rich experience working with apache beam,where i built both batch and streaming pipelines which uses other GCP services for integration like bigquery, gcs, pubsub. I mostly used java for writing the pipelines. I can quickly able to help you to get started with beam and running it in dataflow service. Let's get connected to discuss further.