python 异步程序 dramatiq
安装
Redis
python3.6 -m pip install 'dramatiq[redis, watch]'
代码
example.py
import dramatiq
import requests
from dramatiq.brokers.redis import RedisBroker
redis_broker = RedisBroker(host="127.0.0.1", port=6379)
dramatiq.set_broker(redis_broker)
@dramatiq.actor
def count_Words(url):
print(url)
count_words.send("Http://example.com")
执行
// watch . 代码 动态检测 代码是否更新,然后自动重启
dramatiq example --watch .
相关文章