notifications_consumer.py 410 B

123456789101112
  1. import redis
  2. import json
  3. import os
  4. r = redis.Redis()
  5. token = os.environ.get('token')
  6. while True:
  7. notification = json.loads(r.blpop('notifications')[1].decode('ascii'))
  8. print(notification)
  9. for chat in notification['chats']:
  10. requests.get("https://api.telegram.org/bot{}/sendMessage".format(token), params={"chatid": chat, "text": "New cert for *{}*".format(domain), "parse_mode": "Markdown"})