listener.py 327 B

1234567891011
  1. import redis, os
  2. UPLOAD_DIR = '/storage/'
  3. r = redis.StrictRedis()
  4. pubsub = r.pubsub()
  5. pubsub.psubscribe("*")
  6. for msg in pubsub.listen():
  7. if msg['channel'].decode('utf-8') == '__keyevent@0__:expired':
  8. os.remove(UPLOAD_DIR + msg['data'].decode('utf-8'))
  9. print("Deleted file " + msg['data'].decode('utf-8'))