统计消息的反应次数，达到一定数量后执行动作

import redis
import time

# 连接到Redis服务器
r = redis.Redis(host='localhost', port=6379, db=0)

def record_reaction(user_id, message_id):
    key = f"reaction:{user_id}:{message_id}"
    r.incr(key)
    r.expire(key, 3600)  # 设置过期时间为1小时

def check_and_execute_action(user_id, message_id, threshold):
    key = f"reaction:{user_id}:{message_id}"
    count = int(r.get(key) or 0)
    if count >= threshold:
        print(f"Threshold reached for user {user_id} and message {message_id}. Executing action...")
        # 执行特定动作，例如发送通知
        send_notification(user_id, message_id)
        r.delete(key)  # 重置计数器

def send_notification(user_id, message_id):
    # 模拟发送通知
    print(f"Sending notification to user {user_id} for message {message_id}")

# 模拟用户反应
user_id = 123
message_id = 456
threshold = 5

for _ in range(6):
    record_reaction(user_id, message_id)
    check_and_execute_action(user_id, message_id, threshold)
    time.sleep(1)