需求

获取 kafka 消息，其数据杂乱无章，有字符串格式、有 json 串格式

仅获取 json 串格式的数据进行分析

既抛异常为非json格式数据 

import json


def is_json(text):
    try:
        json_object = json.loads(text)
        return True
    except ValueError as e:
        return False