使用google-cloud-dataflow beam.io.avroio.WriteToAvro将csv转换为python in python

Using google-cloud-dataflow/Cloud Composer for CSV to Avro and everything works on my local environment. When trying to read the .avsc file that contains the Avro schema from a Cloud Storage bucket, I keep getting: IOError: [Errno 2] No such file or directory:'gs://my-bucket/xxx.avsc'Using google-cloud-dataflow/Cloud Composer for