如何使用Redis实现分布式计算功能

import redis

# 连接Redis实例
r = redis.Redis(host='localhost', port=6379, db=0)

# 生产者将任务放入队列
def enqueue_task(queue, task):
    r.lpush(queue, task)

# 消费者从队列中获取任务
def dequeue_task(queue):
    task = r.rpop(queue)
    return task
    

# 生产者将任务放入队列
enqueue_task('task_queue', 'task1')
enqueue_task('task_queue', 'task2')

# 消费者从队列中获取任务
task = dequeue_task('task_queue')
print(task)

import redis

# 连接Redis实例
r = redis.Redis(host='localhost', port=6379, db=0)

# 保存任务结果
def save_result(task_id, result):
    r.hset('result', task_id, result)

# 获取任务结果
def get_result(task_id):
    result = r.hget('result', task_id)
    return result

# 计算节点执行任务
def compute_task(task):
    # 执行任务的代码
    result = 'result'
    save_result(task, result)


# 保存任务结果
save_result('task1', 'result1')

# 获取任务结果
result = get_result('task1')
print(result)