https://cassio-bolba.medium.com/apache-beam-python-and-gcp-deploying-a-streaming-pipeline-on-google-dataflow-using-pubsub-fe6a1a3222e9