9

我正在尝试建立一个从 Luigi 记录的策略，以便有一个可配置的输出列表，包括标准输出和自定义文件列表。我希望能够在运行时设置日志记录级别。我们的系统使用 Luigi 从 Jenkins 调用 spark。先感谢您。

4

2 回答 2

13

在任何 Task 类方法中，您可以执行以下操作：

class Agg(luigi.Task):
  _date = luigi.DateParameter()

  def output(self):
    return luigi.LocalTarget("file_%.txt" % self._date)

  def run(self):
    # Use the luigi-interface to log to console
    logger = logging.getLogger('luigi-interface')
    logger.info("Running --> Agg.Task")
于 2019-03-31T17:24:25.430 回答
-1

你检查过配置的logging_conf_file参数吗？您可以使用 Python 的标准日志记录机制在那里设置有关日志记录的所有配置。

有关一些示例，请参见：

于 2016-06-20T10:24:16.290 回答