Python 分布式任务处理库 Dramatiq

• 授权协议: LGPL-3.0
• 开发语言: Python
• 操作系统: 跨平台
• 软件首页: https://dramatiq.io/
• 软件文档: https://dramatiq.io/
• 官方下载: https://github.com/Bogdanp/dramatiq

软件介绍

Dramatiq 是一个 Python 3 （3.5或更高版本）分布式任务处理库，特点是简单、可靠和高性能。

Demo

import dramatiq
import requests

@dramatiq.actor
def count_words(url):
   response = requests.get(url)
   count = len(response.text.split(" "))
   print(f"There are {count} words at {url!r}.")

# Synchronously count the words on example.com in the current process
count_words("http://example.com")

# or send the actor a message so that it may perform the count
# later, in a separate process.
count_words.send("http://example.com")

使用

与 RabbitMQ 一起使用：

$ pip install -U dramatiq[rabbitmq, watch]

与 Redis 一起使用：

$ pip install -U dramatiq[redis, watch]

具体使用方法阅读 Motivation 或 User Guide。

本文地址：https://www.codercto.com/soft/d/13838.html