'ctypes.ArgumentError on TDengine unsubscribe method
I use python connector to connect the TDengine server for subscribing data stream.
My code is following:
import time
import taos
from taos import taos_unsubscribe
def cb_wrapper(p_sub, p_result, p_param, errno):
result = TaosResult(p_result)
result.check_error(errno)
print(result.row_count)
TAOS = {
'host': '10.3.59.49',
'port': 6030,
'user': 'mizar',
'password': '123456'
}
session = taos.connect(**TAOS)
sub=session.subscribe(restart=True, topic='test_sub', sql=f"select * from tick_quotation.`XSHE_000333_dev`", interval=1000, callback=cb_wrapper)
time.sleep(10)
taos_unsubscribe(sub, True)
But what I see is following error:
ArgumentError Traceback (most recent call last)
in
17 sub=session.subscribe(restart=True, topic='test_sub', sql=f"select * from tick_quotation.XSHE_000333_dev
", interval=1000, callback=cb_wrapper)
18 time.sleep(10)
---> 19 taos_unsubscribe(sub, True)
/usr/local/python3/lib/python3.7/site-packages/taos/cinterface.py in taos_unsubscribe(sub, keep_progress) 337 def taos_unsubscribe(sub, keep_progress): 338 """Cancel a subscription""" --> 339 _libtaos.taos_unsubscribe(sub, 1 if keep_progress else 0) 340 341
ArgumentError: argument 1: <class 'TypeError'>: Don't know how to convert parameter 1
Could someone point me what's wrong?
Sources
This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.
Source: Stack Overflow
Solution | Source |
---|