'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