0
팀에서 수행중인 일부 테스트를위한 자동화 프레임 워크를 개발 중입니다. 우리는이 산세 오류 가로 질러 몇 가지 조사를 수행 한 후 온, 나는 솔루션의 숫자를 가로 질러 와서 첨부 GitHub의 페이지 검토 :이 링크에서Pathos 다중 처리 산세 문제
- Python multiprocessing pickling error
- Multiprocessing: How to use Pool.map on a function defined in a class?
- Pickling issue with python pathos <을 --- , 나는 코드가 올바른 라이브러리를 참조하고 있음을 확인했다.
- https://github.com/uqfoundation/pathos
나는 비애를 설치하고 내가 올바르게 구현하지만 난 여전히 산세 오류를 얻고있다 생각합니다.
import multiprocess
collect_host = 'test_host'
collect_name = 'test_collect'
username = 'user'
start_func = test_start_callback(perf_collect=collect_name,
perf_user=username,
perf_host=collect_host,
password= password)
dpool = multiprocess.Pool(1)
args = ('', '')
worker_results = []
worker = dpool.apply_async(start_func, args)
worker_results.append(worker)
dpool.close()
dpool.join()
for result in worker_results:
result.wait()
r = result.get()
assert r, 'No results returned'
test_start_callback는 인수가없는 함수를 생성하는 공장 기능은 다음과 같습니다 여기에 샘플 코드 및 추적이다. 사용되지 않는 코드 세그먼트를 편집했습니다.
def test_start_callback(dim_collect_host=None, dim_collect_user=None,
perf_host=None, perf_user=None, perf_collect=None,
password=None, tpcc_filename=None):
if perf_host and perf_user and perf_collect:
def perf_test_start():
from <internal> import PerfmonManager
perf = PerfmonManager(host=perf_host,
username=perf_user,
password=password,
collect_name=perf_collect)
perf.start_collect()
return perf_test_start
나는 그것을 놓치고 무엇
는 SO 다른 링크를 언급하거나 나도 페이 소스가 지원하지 않는이 기능을 전달하고있어 방법입니다되지 않았습니다.