Go语言GCP Cloud Function运行Dataflow导入Spanner作业遇连接错误

参考Apache Beam的wordcount示例及谷歌云支持建议，编写了如下代码用于运行Dataflow导入作业：

flag.Parse()
flag.Set("runner", "dataflow")
flag.Set("project","xxxx rp")
flag.Set("region", "us-central1")
flag.Set("staging_location", "gs://xxx/temp")
flag.Set("job_name", "import-delivery_schedule")
beam.Init()
p := beam.NewPipeline()
p.Root()
if err := beamx.Run(context.Background(), p); err != nil {
    log.Fatalf("Failed to execute job: %v", err)
}

云函数、Dataflow导入作业与数据库处于同一项目，该导入作业在控制台中可成功运行，但通过云函数运行时无法正常工作，报错信息为：函数执行耗时18毫秒，最终状态：'连接错误'

• 检查网络配置：云函数默认使用公网，若依赖的数据库或Dataflow资源在私有网络内，需配置云函数接入对应VPC，保证网络连通性。
• 验证权限完整性：即便同项目，云函数的服务账号可能缺少Dataflow作业提交、GCS存储访问或数据库连接的权限。需确认该账号拥有roles/dataflow.developer、roles/storage.objectAdmin（对应staging存储桶）及数据库相关访问权限。
• 调整云函数超时：当前执行仅18毫秒就报错，大概率是初始化Dataflow客户端或建立连接时超时。可将云函数超时时间调至5分钟左右，避免初始化过程未完成就被终止。
• 修正项目ID格式：代码中project参数值包含空格（"xxxx rp"），而谷歌云项目ID不允许空格，需检查并修正为正确的项目ID。
• 增加日志排查：在代码中添加更多日志输出，比如打印初始化阶段的错误详情、服务账号身份信息等，精准定位连接失败的具体环节。

内容的提问来源于stack exchange，提问作者Darryl Landvater