Files
dss.api/core/realtime/activity.py
Fergal Moran e5fc34ed47 Pre switch
2015-10-15 20:03:32 +01:00

18 lines
503 B
Python
Executable File

import logging
import redis
import json
from dss import settings
logger = logging.getLogger('dss')
def post_activity(channel, message, session=''):
r = redis.StrictRedis(host=settings.REDIS_HOST, port=6379, db=0)
payload = json.dumps({'session': session, 'message': message})
response = r.publish(channel, payload)
logger.debug("Message sent: {0}".format(payload))
if __name__ == '__main__':
post_activity('site:broadcast', 'bargle', '3a596ca6c97065a67aca3dc4a3ba230d688cf413')