从ray的worker节点中的远程功能获取日志的正确方法

问题描述

在How can I use the python logging in Ray?处提出了类似的问题，但提供的解决方案对我不起作用

我无法从stdout / logfile中的worker节点获取日志。警告和错误日志显示在stdout中，具有不同的pid，但未显示低于log.warning级别的其他日志。标准输出示例如下所示。我在ray 1.0.0和0.9dev版本上都尝试过。在此之前以及在stackoverflow上都提出了类似的问题，但在此提到它已得到纠正。对于工作节点ray.init，我将日志记录级别设置为DEBUG仍然面临问题。

ray.init(address=ray_cluster_addr,ignore_reinit_error=True,logging_level=10)

如果我缺少任何东西，有人可以帮忙吗

2020-10-15 13:49:35,907 ERROR worker.py:643 -- Calling ray.init() again after it has already been called.
2020-10-15 13:49:35.908 INFO - emagent.py - start_em_worker[63] Running EM algorithm on sample file 
(pid=92) Ignoring first 2 columns in init_b_params
(pid=92) Ignoring first 2 columns in init_b_params    


  [1]: https://stackoverflow.com/questions/55272066/how-can-i-use-the-python-logging-in-ray

解决方法

请参考这个Github讨论线程。 https://github.com/ray-project/ray/discussions/11426

python ray