gcloud dataflow flex-template run - runs a job from the specified path

gcloud dataflow flex-template runJOB_NAME--template-file-gcs-location=TEMPLATE_FILE_GCS_LOCATION[--additional-experiments=[ADDITIONAL_EXPERIMENTS,…]][--additional-pipeline-options=[ADDITIONAL_PIPELINE_OPTIONS,…]][--additional-user-labels=[ADDITIONAL_USER_LABELS,…]][--dataflow-kms-key=DATAFLOW_KMS_KEY][--disable-public-ips][--enable-streaming-engine][--flexrs-goal=FLEXRS_GOAL][--launcher-machine-type=LAUNCHER_MACHINE_TYPE][--max-workers=MAX_WORKERS][--network=NETWORK][--num-workers=NUM_WORKERS][--parameters=[PARAMETERS,…]][--region=REGION_ID][--service-account-email=SERVICE_ACCOUNT_EMAIL][--staging-location=STAGING_LOCATION][--subnetwork=SUBNETWORK][--temp-location=TEMP_LOCATION][--worker-machine-type=WORKER_MACHINE_TYPE][[--[no-]update :--transform-name-mappings=[TRANSFORM_NAME_MAPPINGS,…]]][--worker-region=WORKER_REGION    |--worker-zone=WORKER_ZONE][GCLOUD_WIDE_FLAG …]

JOB_NAME

Unique name to assign to the job.

--template-file-gcs-location=TEMPLATE_FILE_GCS_LOCATION

Google Cloud Storage location of the flex template to run. (Must be a URLbeginning with 'gs://'.)

--additional-experiments=[ADDITIONAL_EXPERIMENTS,…]

Additional experiments to pass to the job. Example:--additional-experiments=experiment1,experiment2=value2

--additional-pipeline-options=[ADDITIONAL_PIPELINE_OPTIONS,…]

Additional pipeline options to pass to the job. Example:--additional-pipeline-options=option1=value1,option2=value2

--additional-user-labels=[ADDITIONAL_USER_LABELS,…]

Additional user labels to pass to the job. Example:--additional-user-labels='key1=value1,key2=value2'

--dataflow-kms-key=DATAFLOW_KMS_KEY

Cloud KMS key to protect the job resources.

--disable-public-ips

Cloud Dataflow workers must not use public IP addresses. Overrides the defaultdataflow/disable_public_ips property value for this commandinvocation.

--enable-streaming-engine

Enabling Streaming Engine for the streaming job. Overrides the defaultdataflow/enable_streaming_engine property value for this commandinvocation.

--flexrs-goal=FLEXRS_GOAL

FlexRS goal for the flex template job.FLEXRS_GOAL mustbe one of:COST_OPTIMIZED,SPEED_OPTIMIZED.

--launcher-machine-type=LAUNCHER_MACHINE_TYPE

The machine type to use for launching the job. The default isn1-standard-1.

--max-workers=MAX_WORKERS

Maximum number of workers to run.

--network=NETWORK

Compute Engine network for launching instances to run your pipeline.

--num-workers=NUM_WORKERS

Initial number of workers to use.

--parameters=[PARAMETERS,…]

Parameters to pass to the job.

--region=REGION_ID

Region ID of the job's regional endpoint. Defaults to 'us-central1'.

--service-account-email=SERVICE_ACCOUNT_EMAIL

Service account to run the workers as.

--staging-location=STAGING_LOCATION

Default Google Cloud Storage location to stage local files.(Must be a URLbeginning with 'gs://'.)

--subnetwork=SUBNETWORK

Compute Engine subnetwork for launching instances to run your pipeline.

--temp-location=TEMP_LOCATION

Default Google Cloud Storage location to stage temporary files. If not set,defaults to the value for --staging-location.(Must be a URL beginning with'gs://'.)

--worker-machine-type=WORKER_MACHINE_TYPE

Type of machine to use for workers. Defaults to server-specified.

--[no-]update

Set this to true for streaming update jobs. Use--update to enableand--no-update to disable.

--transform-name-mappings=[TRANSFORM_NAME_MAPPINGS,…]

Transform name mappings for the streaming update job.

At most one of these can be specified:

--worker-region=WORKER_REGION

Region to run the workers in.

--worker-zone=WORKER_ZONE

Zone to run the workers in.

Run$gcloud help for details.