如何运行用 Golang 编写的 GCP Cloud Function 来运行 Dataflow 作业以将文本文件导入 Spanner？

Question

我使用了示例：https://github.com/apache/beam/blob/master/sdks/go/examples/wordcount/wordcount.go#L82 以及 Google Cloud Support 的建议，使用以下内容运行数据流导入作业：

    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)
    }

云函数与数据库在同一个项目中。 数据流导入作业与数据库位于同一项目中。 导入作业从控制台成功运行。

但是，我无法让它工作。

我收到此错误：“函数执行耗时 18 毫秒，完成状态为：‘连接错误’”

Answer 1

我对将文本文件导入扳手表的其他方法持开放态度。你有什么建议？