blob: b33ceed718501c8ecb1dfb25e05f9f41373fa237 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
|
import os, redis, json, time
from configure import REDIS_CHANNEL
def publish():
redis_host = os.getenv('REDIS_HOST', '127.0.0.1')
redis_password = os.getenv('REDIS_PASSWORD', '123456')
r = redis.Redis(host=redis_host, port=6379, password=redis_password, db=0)
r.publish(REDIS_CHANNEL, json.dumps({'filename':'a.txt', 'data':'123'}))
while True:
publish()
time.sleep(3)
|
