RPYC로 다중 처리 Python "ValueError : pickling is disabled"

Question

rpyc 서비스 내에서 멀티 프로세싱 패키지를 사용하려고하지만 클라이언트에서 노출 된 함수를 호출하려고하면 ValueError: pickling is disabled이 표시됩니다. multiprocesing 패키지는 절건을 사용하여 프로세스간에 정보를 전달하며 안전하지 않은 프로토콜이기 때문에 rpyc에 절임이 허용되지 않음을 알고 있습니다. 그래서 rpyc로 다중 처리를 사용하는 것이 가장 좋은 방법인지 (또는 어쨌든 존재한다면) 확신 할 수 없다. rpyc 서비스 내에서 다중 처리를 사용하려면 어떻게해야합니까? 여기

import rpyc 
from multiprocessing import Pool 

class MyService(rpyc.Service): 

    def exposed_RemotePool(self, function, arglist): 

     pool = Pool(processes = 8) 
     result = pool.map(function, arglist) 
     pool.close() 
     return result 


if __name__ == "__main__": 
    from rpyc.utils.server import ThreadedServer 
    t = ThreadedServer(MyService, port = 18861) 
    t.start() 

그리고 오류를 생성하는 클라이언트 측 코드입니다 :

이

import rpyc 

def square(x): 
    return x*x 

c = rpyc.connect("localhost", 18861) 
result = c.root.exposed_RemotePool(square, [1,2,3,4]) 
print(result) 

Answer 1

프로토콜 구성에서 산세를 활성화 할 수 있습니다. 구성은 사전으로 저장되며 default을 수정하여 서버 (protocol_config =)와 클라이언트 (config =) 모두에 전달할 수 있습니다. 또한 클라이언트와 서버 측에서 병렬 처리되는 함수를 정의해야합니다. 그래서 여기 server.py의 전체 코드는 다음과 같습니다

import rpyc 
from multiprocessing import Pool 
rpyc.core.protocol.DEFAULT_CONFIG['allow_pickle'] = True 

def square(x): 
    return x*x 


class MyService(rpyc.Service): 

    def exposed_RemotePool(self, function, arglist): 

     pool = Pool(processes = 8) 
     result = pool.map(function, arglist) 
     pool.close() 
     return result 



if __name__ == "__main__": 
    from rpyc.utils.server import ThreadedServer 
    t = ThreadedServer(MyService, port = 18861, protocol_config = rpyc.core.protocol.DEFAULT_CONFIG) 
    t.start() 

그리고 client.py의 코드는 다음과 같습니다

import rpyc 

rpyc.core.protocol.DEFAULT_CONFIG['allow_pickle'] = True 

def square(x): 
    return x*x 

c = rpyc.connect("localhost", port = 18861, config = rpyc.core.protocol.DEFAULT_CONFIG) 
result = c.root.exposed_RemotePool(square, [1,2,3,4]) 
print(result) 

Answer 2

당신은 프로토콜 구성에서 활성화해야 다음은 서버 측 코드입니다. http://rpyc.readthedocs.org/en/latest/api/core_protocol.html#rpyc.core.protocol.DEFAULT_CONFIG