#distributed process

예제 – ZMQ + Asyncio 로 PUSH-PULL 구성

PUSH-PULL 구조를 사용한 분산처리를 구현한 예제를 asyncio 버전으로 재작성해보았다. 벤틸레이터가 보내는 값에 대해 각각의 워커는 그 값에 해당하는 시간만큼 지연시킨 후 싱크에게 짝/홀수 여부값을 전송한다.

워커

import sys import random import asyncio import zmq import zmq.asyncio ctx = zmq.asyncio.Context() async def run_worker(portA=5556, portB=5557): sock_pull = ctx.socket(zmq.PULL) sock_pull.connect(f'tcp://localhost:{portA}') sock_push =…