Я попытался выполнить свой код потока данных python с указанным ниже аргументом командной строки.
python upload_simple_csv.py --runner DataflowRunner --project bigquery-poc-188207 --save_main_session True --temp_location gs: //resources-poc-atul / temp --num_workers 1
https://console.cloud.google.com/dataflow
Но в то же время, когда я отправляю другое задание потока данных, оно появляется в списке.например: python spikey_top_selling_products.py --input gs: // resources-poc-atul / data / spikey_sales_we ekly.csv --output gs: // resources-poc-atul / output / --runner DataflowRunner --project bigquery-poc-188207 --temp_location gs: // resources-poc-atul / temp / --num_workers = 4 --save_main_session TR UE