Python接口_v1

导入

把 esqlx.x.x/api/python/v1/esql_api.py 复制到项目所在目录, 并在需要调用esql的程序中导入

from esql_api import ESql

ESql接口类定义

class ESql(object):
    def __init__(self, host='127.0.0.1', port=8001, username=None, password=None):
    def execute(self, sql):

创建ESQL实例

esql = ESql('esql_server_ip_address', 8001, 'username', 'password')

服务器开启免认证模式时，无需设置 username / password ，也无需登录（login）：

esql = ESql('esql_server_ip_address', 8001)

执行SQL

result = esql.execute('show version;')

返回的数据字典(result).

完整的API调用样例

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
import os
import json

from esql_api import ESql

if __name__ == '__main__':

    # esql = ESql('10.68.23.81', 8001, 'root', 'toor')
    esql = ESql('127.0.0.1', 8001, 'root', 'toor')
    
    if esql.error:
        print('ERROR: %s' % esql.error)
        exit(1)
    # print(esql.execute('show version;'))
    print(esql.execute('show tables;'))