backup/seal
1
0
Fork 0
mirror of https://github.com/hequan2017/seal.git synced 2026-04-25 19:20:47 +08:00
Code Issues Projects Releases Wiki Activity

0.1.1 增加异步程序 选择

Browse Source
This commit is contained in:
何全
2019-03-19 10:42:02 +08:00
parent 182460ca8e
commit f79661c783
4 changed files with 33 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

0
system/decorator/asynchronous/__init__.py Normal file
View File

12
system/decorator/asynchronous/asynchronous.py Normal file
View File

@@ -0,0 +1,12 @@
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")