dramatiq_redis_broker_background_task_word_counter.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# To enqueue a message:
17# count_words.send("https://dramatiq.io")