提交 27723581 编写于 作者: G Ganlin Zhao

[TD-10642]<enhance>: [schemaless] modified python connector to

accomandate API change
上级 d9a5b7c3
......@@ -816,17 +816,19 @@ except AttributeError:
def taos_schemaless_insert(connection, lines, protocol, precision):
def taos_schemaless_insert(connection, lines, protocol, precision, msg_size=512):
# type: (c_void_p, list[str] | tuple(str)) -> None
num_of_lines = len(lines)
lines = (c_char_p(line.encode("utf-8")) for line in lines)
lines_type = ctypes.c_char_p * num_of_lines
p_lines = lines_type(*lines)
if precision != None:
if precision is not None:
precision = c_char_p(precision.encode("utf-8"))
errno = _libtaos.taos_schemaless_insert(connection, p_lines, num_of_lines, protocol, precision)
a_lines = c_int()
msg = create_string_buffer(msg_size)
errno = _libtaos.taos_schemaless_insert(connection, p_lines, num_of_lines, protocol, precision, byref(a_lines), msg, msg_size)
if errno != 0:
raise SchemalessError("schemaless insert error", errno)
raise SchemalessError("schemaless insert error({}), affected_rows({})".format(msg.value.decode("utf-8"), a_lines.value), errno)
class CTaosInterface(object):
def __init__(self, config=None):
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册