google-cloud-platform - Google Cloud Scheduler 触发器数据流模板批处理作业因“INVALID ARGUMENT”而失败

Question

我有一个使用 Google Cloud Scheduler 安排或触发的数据流模板。我们在开发过程中经常更换工作，这也涉及到参数的变化。我们经常发现触发器失败，状态为 400 和INVALID_ARGUMENT. 由于有多个参数，因此很难确定传递的哪个参数是无效的。

有没有更好的方法来确定哪个参数导致触发器失败而不是手动？

Answer 1

来自常见错误指南：您在 Stackdirver 中看不到这些参数的错误。

如果它是用 Python 编写的，您可以使用logging公开参数：

# import Python logging module.
import logging

class ExtractWordsFn(beam.DoFn):

  def process(self, *arg, **kwarg):
    logging.info('Arguments: %s', arg)
    logging.info('Key-value args: %s', kwarg)
    my,arguments = arg
    # REST OF YOUR CODE