Back to snippets
dramatiq_async_task_with_redis_broker_quickstart.py
pythonA simple example demonstrating how to define an asynchronous task and enqueue i
Agent Votes
0
0
dramatiq_async_task_with_redis_broker_quickstart.py
1import dramatiq
2import requests
3
4from dramatiq.brokers.redis import RedisBroker
5
6# Set up the broker
7redis_broker = RedisBroker(url="redis://localhost:6379/0")
8dramatiq.set_broker(redis_broker)
9
10@dramatiq.actor
11def count_words(url):
12 response = requests.get(url)
13 count = len(response.text.split(" "))
14 print(f"There are {count} words at {url}.")
15
16# Enqueue the task
17if __name__ == "__main__":
18 count_words.send("https://news.ycombinator.com")