#pub REDISIO_PASSWORD = os.environ.get("CRAWLER_REDISIO_KEY") redisClient = redis.StrictRedis(host='188.166.1.146', port=6379, db=0, password=REDISIO_PASSWORD) redisClient.publish('NetsuiteMonitoringAlarmsChannel', alarmData) # subs redisClient=mtutils.getRedisClient() subs=redisClient.pubsub() subs.subscribe("NetsuiteMonitoringAlarmsChannel") for alarmItem in subs.listen(): #do task