具有多进程的python zerorpc客户端将日志发送到服务器

Question

作为标题，我想要一个log-rpc服务器来帮助我在新进程中处理日志。

我引用zerorpc和这个链接：https://stackoverflow.com/a/57140017/14021161

但陷入了一个奇怪的错误

代码：

import zerorpc
from loguru import logger
import time
import multiprocessing as mp
import collections
Job = collections.namedtuple('Job', ['event', 'args'])
class LogClient(mp.Process):
"""A process backed by an internal queue for simple one-way message passing.
"""
def __init__(self, ip='127.0.0.1', port='4242'):
super().__init__()
self.queue = mp.Queue()
self.c = zerorpc.Client()
address = f"tcp://{ip}:{port}"
self.c.connect(address)
self.start()
def put(self, event, *args):
"""Puts the event and args as a `Job` on the queue
"""
job = Job(event, args)
self.queue.put(job)
def _addLog(self, job):
event, args = job
self.c.addLog(*args)
def run(self):
while True:
job = self.queue.get()
self._addLog(job)
def addLog(self, level, *context):
self.put('addLog', level, *context)


lc = LogClient()
lc.c.addLog("WARNING", 'hello', 'Ray')  # this work, but its witout multiprocess
lc.addLog("INFO", 'hello', 'Ray')  # doesn't work 
lc.terminate()

_addLog确实收到了作业，但并没有真正将其发送到服务器

任何建议都将不胜感激！提前谢谢。

|

|

---

p.s.为了明确问题，我只显示了addLog，但实际上服务器应该处理许多IO作业。因此_addLog函数将变为具有gettattr的dispatch函数，以解析服务器中的所有函数

Answer 1

我发现zerorpc出现了这个问题。

在尝试了grpc之后，它很快，但有很多细节反对我的轻项目。。。

我最终使用了带有PUSH-PULL模式的纯zeromq。