python实现Doris的streamLoad
# StreamLoad函数【新增】
def json_serial(obj):if isinstance(obj, (datetime, date)):return obj.strftime("%Y-%m-%d %H:%M:%S")raise TypeError(f"Object of type {type(obj).name} is not JSON serializable")def doris_stream_load(data_rows: Li…
2026/8/21 10:45:55