kqkdChen opened a new issue #1446:
URL: https://github.com/apache/incubator-iotdb/issues/1446


   一、我修改了root用户密码,并且重启了server
   二、使用 python paho mqtt 插入数据时,没有设置用户名和密码相关参数
   三、但是我仍然成功的插入了数据 **-_-!!!**
   
   iotdb version: 0.10.0
   paho mqtt: 1.5.0    (pip install paho-mqtt)
   
   代码如下:
   ```python
   from time import *
   import paho.mqtt.publish as publish
   
   
   def timestamp():
       return int(round(time() * 1000))
   
   
   def single(tx_id: str, log_type: str, log_content: str, hostname: str = 
"192.168.3.181", port: int = 1883):
       device_id = "root.log.%s" % tx_id
       payload = "{\n" "\"device\":\"%s\",\n" "\"timestamp\":%d,\n" 
"\"measurements\":[\"type\",\"content\"],\n" "\"values" \
                 "\":[\"%s\",\"%s\"]\n" "}" % (device_id, timestamp(), 
log_type, log_content)
       publish.single(topic=device_id, payload=payload, hostname=hostname, 
port=port)
   
   
   if __name__ == '__main__':
       type_list = ["INFO", "WARNING", "ERROR"]
       content_list = ["自动上报: 组件不完整", "日志同步", "命令长度校验失败", "配置参数有误"]
       begin_time = time()
       for i in range(10):
           single("1411111111", type_list[i % len(type_list)], content_list[i % 
len(content_list)])
       end_time = time()
       run_time = end_time - begin_time
       print('该循环程序运行时间:', run_time)
   ```
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to