notifications_consumer.py 457 B

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