IPython.并行-我可以写我自己的日志到引擎日志

Question

我希望能够在相关的引擎日志中记录我传递给引擎的函数的输出。

即:

data = /* my list of data to operate on */
def fn(inval):
    import logging
    log = logging.getLogger()
    log.error('This is on the engine')
    // do stuff
    return result
calculated_data = []
for datum in data:
    calc = view.apply(fn, datum)
    calculated_data.append(calc)

我希望能够看到在特定任务上操作的相关引擎日志中的日志语句。

Answer 1

你可以抓取当前应用程序的日志(即在这种情况下的引擎):

from IPython.config import Application
log = Application.instance().log

然后正常记录，它将进入引擎日志