DEVOCEAN

import redis
import time

REDIS_HOST = 'localhost'
TASK_QUEUE = 'task_queue'
RESULT_CHANNEL = 'task_result'

def main():
    r = redis.Redis(host=REDIS_HOST, port=6379, db=0)
    pubsub = r.pubsub()
    pubsub.subscribe(RESULT_CHANNEL)

    # 작업 큐에 작업 넣기
    for i in range(5):
        task = f"do_something:{i}"
        r.rpush(TASK_QUEUE, task)
        print(f"[SERVER] Queued: {task}")

    print("[SERVER] Waiting for results...")
    received = 0
    while received < 5:
        message = pubsub.get_message()
        if message and message['type'] == 'message':
            print(f"[SERVER] Result received: {message['data'].decode()}")
            received += 1
        time.sleep(0.1)

if __name__ == "__main__":
    main()

import redis
import time

REDIS_HOST = 'localhost'
TASK_QUEUE = 'task_queue'
RESULT_CHANNEL = 'task_result'

def main():
    r = redis.Redis(host=REDIS_HOST, port=6379, db=0)
    print("[WORKER] Waiting for tasks...")
    while True:
        task = r.blpop(TASK_QUEUE, timeout=0)
        if task:
            task_data = task[1].decode()
            print(f"[WORKER] Processing: {task_data}")
            # 실제 작업 처리 (예시로 2초 sleep)
            time.sleep(2)
            result = f"{task_data} done"
            r.publish(RESULT_CHANNEL, result)
            print(f"[WORKER] Published result: {result}")

if __name__ == "__main__":
    main()