问题标签 [value-provider]

运行测试用例成功但数据库中的数据未更新时，我收到系统空异常，该异常可通过使用控制器上下文解决但无法更新数据

控制器代码

我想要一个 Dataflow 模板，其中一个 PipelineOptions 参数具有默认值。

受在线示例的启发，我在我的 PipelineOptions“子”界面中使用 ValueProvider 占位符进行延迟参数设置：

如果我在运行时指定参数，则模板可用于启动真正的 GCP Dataflow 作业。但是，如果我在实际执行此操作之前尝试测试不包括参数：

然后，当我的 TestPipeline 执行需要参数的 DoFn processElement 方法时，我得到

更具体地说，它在 org.apache.beam.sdk.options.ValueProvider 中失败：

认为运行时是管道运行时可能是可以原谅的。

无论如何，有人知道我将如何对默认参数进行单元测试，假设顶部代码片段应该如何设置并且受支持？谢谢你。

我正在尝试使用 Cloud Scheduler 创建每天运行的 Dataflow 作业。我需要使用 GET 请求从外部 API 获取数据，所以我需要当前日期作为输入。但是，当我将数据流作业导出为调度模板时，日期输入停留在执行时，而不是每天更新。我一直在寻找解决方案，并遇到了 ValueProvider，但我的管道apache_beam.transforms.Create始终返回错误'RuntimeValueProvider(option: test, type: str, default_value: 'killme').get() not called from a未指定 ValueProvider 时的运行时上下文。

无论如何我可以克服这个吗？这似乎是一个简单的问题，但无论如何我都无法让它工作。如果有任何想法，我将不胜感激！！

每当我调用 .py 文件并使用 argparse 库提供的参数时，我都可以运行自定义流程。但是，当我尝试将我的参数转换为运行时参数时，它不起作用。这是作为独立管道的代码示例：

问题是，我如何将这个管道变成一个可模板化的管道，特别是当我需要使用运行时参数来定义我的查询和我想要编辑的单词列表时？在将 argparse 转换为管道选项并将它们转换为 add_value_provider_argument 时，它说我不能连接字符串和运行时值，这是有道理的，但我仍然需要一个解决方法。

我已经尝试过的：

参考资料：https ://cloud.google.com/dataflow/docs/guides/templates/creating-templates

早上好，

我创建了一个 DataFlow 模板，用于读取 BigQuery 中的一些信息、应用一些转换并将结果写入一个新的 BigQuery 表中。

该模板采用 2 个参数：

• 输入查询
• 项目名称

我想通过“WriteToBigquery”转换将项目名称写入 bigquery 表中，但不是写入用户填写的项目名称，而是返回错误..

你知道我怎样才能得到这个值并写下来吗？

谢谢你的帮助！

代码 ：

如果我需要在提供输入值之前对输入值执行一些转换，我会成功使用 NestedValueProvider。

但是，如果我需要结合 2+ 值输入，我应该怎么做？

在文档中它说：

来自微软文档：

默认情况下，模型绑定从 HTTP 请求中的以下来源以键值对的形式获取数据：

1. 表单域
2. 请求正文（对于具有 [ApiController] 属性的控制器。）
3. 路线数据
4. 查询字符串参数
5. 上传的文件

我很想知道有没有一种方法可以从不使用ApiControllerAttribute.

我问这个问题的原因是我们从 asp net 5 迁移到 net core 5，我们希望将模型参数与内容类型请求独立绑定：withcontent-type: x-www-form-urlencoded或 withcontent-type application/json charset=utf-8

我已经阅读了很多关于这个问题的内容，但只发现决定使用本文[FromBody]中描述的属性为每个内容类型分离方法，这不适合我。

我试图在使用 ValueProvider 执行运行命令时获取服务器 ID 作为参数

对于选项接口中的值提供者：

withBootstrapServers 抛出错误“不兼容的类型：org.apache.beam.sdk.options.ValueProvider 无法转换为 java.lang.String”

这个答案建议使用 options.getBootstrapServers().get() 但这会产生以下错误

非常感谢任何解决此问题的帮助