certstream_producer.py 269 B

1234567891011
  1. import certstream
  2. import redis
  3. import sys
  4. r = redis.Redis()
  5. def enqueue(message, context):
  6. for domain in message['data']['leaf_cert']['all_domains']:
  7. r.rpush('certstream', domain)
  8. certstream.listen_for_events(enqueue, url='wss://certstream.calidog.io/')