from celery import shared_task @shared_task(name="tasks.ping") def ping(msg: str = "pong") -> str: """ 示例任务:用于验证 Celery worker 可消费任务。 注意:任务参数请尽量保持小(只传 id/短文本),避免 Redis 队列膨胀。 """ return msg