python 异步程序 dramatiq

发布时间：2019-09-05 07:06:10编辑：auto阅读（3080）

    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 .

关键字：

上一篇： Python 之 SSH简单实例

下一篇： Python 前端框架【Bootstra