connections.py 文件源码

def send_ws(message, signal=consts.WS_NONE, tags=[]):
    from app import app

    _tags = tags if isinstance(tags, list) else [tags]
    msg = {
        'message': {
            'message': message,
            'signal': signal,
            'tags': _tags,
        },
        'tags': _tags,
    }

    redis = StrictRedis(
        app.config['WS_BROKER_HOST'],
        app.config['WS_BROKER_PORT'],
        app.config['WS_BROKER_DB']
    )
    redis.publish(app.config['WS_BROKER_CHANNEL'], json.dumps(msg))