在 jupyter 中测试接收，可以加上这段
```
if __name__ == '__main__':
on_redis_message()
try:
while True:
pass # 保持主线程运行
except KeyboardInterrupt:
print("Exiting...")
```
@db.listener装饰器中的is_async=True意味着回调函数将会在一个单独的线程中异步执行。为了确保主线程不会过早退出，可以在主程序的最后加上一个无限循环或者等待输入的语句来保持主程序的运行
2024-10-18
雪球
