如何在Flex Template中内置sdk_container_image默认值

有可行方案，完全可以把sdk_container_image的默认值内置到Flex Template里，不用每次调用模板都单独传这个参数，常用的实现方式有两种：

• 通过模板元数据文件配置默认值
  构建Flex Template时，支持通过自定义元数据文件定义参数的默认规则。在元数据JSON文件的参数列表中，为sdk_container_image字段配置固定的defaultValue，同时把这个参数标记为可选。构建模板时通过--metadata-file参数传入这个元数据文件，生成的模板就会自带worker镜像的默认配置，调用时如果不主动传参覆盖，Dataflow会自动拉取你配置的默认worker镜像启动任务。
  元数据配置示例如下：

  {
    "parameters": [
      {
        "name": "sdk_container_image",
        "defaultValue": "自定义worker镜像完整地址（建议带固定版本tag，不要用latest）",
        "isOptional": true
      }
      // 其余业务自定义参数
    ]
  }
  

• 在管道定义中直接固化worker镜像配置
  如果不需要在调用模板时灵活替换worker镜像，可以直接在编写Beam管道代码时，把sdk_container_image作为固定配置写入管道选项初始化逻辑，不把它暴露为可传入的模板参数。这种方式会把worker镜像地址直接打包进模板的管道定义里，彻底消除参数漏传、版本错配的问题，完全符合Flex Template自包含的设计目标。
  以Python SDK为例，配置代码如下：

  from apache_beam.options.pipeline_options import PipelineOptions
  # 初始化管道选项时直接固化worker镜像地址
  options = PipelineOptions(
      sdk_container_image="自定义worker镜像完整地址（带固定版本tag）"
  )
  

注意事项：

1. 要保证Dataflow任务使用的worker服务账号，拥有配置的自定义worker镜像的拉取权限，否则模板启动时会报镜像拉取失败的错误。
2. 自定义worker镜像建议使用固定版本tag，不要用latest标签，每次镜像更新同步更新模板内的镜像地址配置，保证构建产物和运行时环境一一对应，满足密封构建的版本一致性要求。

你之前觉得构建阶段没法配置worker镜像，本质是混淆了Flex Template两个镜像的配置入口：gcloud构建Flex Template时--image参数指定的是Flex Template的启动器镜像，而worker镜像属于模板运行参数/管道定义的一部分，本来就支持在构建阶段内置，不需要留到调用环节额外传参。

内容的提问来源于stack exchange，提问作者Martin Stolle