[Doris Stream Load] python调用stream load

586人浏览 / 0人评论

安装requests

pip install requests

python代码


# coding=utf-8
import requests
import time


def main():
    user = 'doris账号'
    password = 'doris密码'
    while 1:
        url = 'http://fe ip:fe http端口/api/库名/表名/_stream_load'
        doris_headers = {
            'label': '导入任务的名字, 每次不一样',
            'column_separator': '分隔符,默认是制表符',
            'Content-Type': 'application/octet-stream'
        }
        response = requests.put(url,
                                data=open(
                                    '文件路径'),
                                headers=doris_headers, auth=(user, password)
                                )
        print(response.text)
        time.sleep(60)


if __name__ == '__main__':
    main()

全部评论