Пакетное задание шаблона потока данных триггера 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