utils.py 文件源码

def sse_encode_event(event_type, data, event_id=None, escape=False):
    data_str = json.dumps(data, cls=DjangoJSONEncoder)
    if escape:
        event_type = build_id_escape(event_type)
        data_str = build_id_escape(data_str)
    out = 'event: %s\n' % event_type
    if event_id:
        out += 'id: %s\n' % event_id
    out += 'data: %s\n\n' % data_str
    return out