Trying to insert data with python paho MQTT

[tishacian]

Describe the bug
When trying inserting data with paho MQTT with :

import paho.mqtt.publish as publish
payload=f"""{{\n"device":"root.synox.alphitan.MD10109",\n"timestamp":100,\n"measurments":["temperature"],\n"values":[20.0]}}"""
publish.single(topic='root.synox.alphitan.MD10109', payload=payload, hostname=MQTT_IOTDB, port=MQTT_IOTDB_PORT, auth={'username':'root', 'password':'root'})

I have an error printing :

ERROR o.a.i.d.c.IoTDBDefaultThreadExceptionHandler:31 - Exception in thread pool-5-thread-5-89
java.lang.NullPointerException: null
	at org.apache.iotdb.db.mqtt.PublishHandler.onPublish(PublishHandler.java:98)
	at io.moquette.interception.BrokerInterceptor.lambda$notifyTopicPublished$3(BrokerInterceptor.java:133)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
	at java.base/java.lang.Thread.run(Unknown Source)

To Reproduce
Steps to reproduce the behavior:

1. Define a docker volume iotdb-conf with inside a modify iotdb-engine.propertiesfile with enable_mqtt_service=trueset.
2. Deploy IotDB docker container with docker run -d -p 6667:6667 -p 31999:31999 -p 8181:8181 -p 1884:1883 -v iotdb-conf:/iotdb/conf -v iotdb-data:/iotdb/data -v iotdb-logs:/iotdb/logs --name iotdb apache/iotdb:latest
3. Try to submit previous python code

Expected behavior
Value of 20.0 to be inserted for temperature.

Desktop (please complete the following information):

• OS: Docker

Additional context
No error raised by publish.single, obviously I have nothing when requesting in IotDB CLI SELECT temperature FROM root.synox.alphitan.MD10109, I can only see the error in IotDB logs.

[github-actions[bot]]

Hi, this is your first issue in IoTDB project. Thanks for your report. Welcome to join the community!

[HTHou]

Hi, I see a spelling mistake. "measurments" -> "measurements".

[tishacian]

Thanks @HTHou, so sorry for dumb typo, it works!

[jerrychong25]

Describe the bug When trying inserting data with paho MQTT with :

import paho.mqtt.publish as publish
payload=f"""{{\n"device":"root.synox.alphitan.MD10109",\n"timestamp":100,\n"measurments":["temperature"],\n"values":[20.0]}}"""
publish.single(topic='root.synox.alphitan.MD10109', payload=payload, hostname=MQTT_IOTDB, port=MQTT_IOTDB_PORT, auth={'username':'root', 'password':'root'})

I have an error printing :

ERROR o.a.i.d.c.IoTDBDefaultThreadExceptionHandler:31 - Exception in thread pool-5-thread-5-89
java.lang.NullPointerException: null
	at org.apache.iotdb.db.mqtt.PublishHandler.onPublish(PublishHandler.java:98)
	at io.moquette.interception.BrokerInterceptor.lambda$notifyTopicPublished$3(BrokerInterceptor.java:133)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
	at java.base/java.lang.Thread.run(Unknown Source)

To Reproduce Steps to reproduce the behavior:

1. Define a docker volume iotdb-conf with inside a modify iotdb-engine.propertiesfile with enable_mqtt_service=trueset.
2. Deploy IotDB docker container with docker run -d -p 6667:6667 -p 31999:31999 -p 8181:8181 -p 1884:1883 -v iotdb-conf:/iotdb/conf -v iotdb-data:/iotdb/data -v iotdb-logs:/iotdb/logs --name iotdb apache/iotdb:latest
3. Try to submit previous python code

Expected behavior Value of 20.0 to be inserted for temperature.

Desktop (please complete the following information):

• OS: Docker

Additional context No error raised by publish.single, obviously I have nothing when requesting in IotDB CLI SELECT temperature FROM root.synox.alphitan.MD10109, I can only see the error in IotDB logs.

Hi @tishacian ,

Good day.

Do you mind to share full working codes and /iotdb/conf/iotb-engine.properties file content?

As my end can't make MQTT code successfully save into IoTDB with similar code, but don't have any errors.

Here is my MQTT config details:

####################
### MQTT Broker Configuration
####################

# whether to enable the mqtt service.
# Datatype: boolean
enable_mqtt_service=true

# the mqtt service binding host.
# Datatype: String
mqtt_host=0.0.0.0

# the mqtt service binding port.
# Datatype: int
mqtt_port=2883

# the handler pool size for handing the mqtt messages.
# Datatype: int
mqtt_handler_pool_size=100

# the mqtt message payload formatter.
# Datatype: String
mqtt_payload_formatter=json

# max length of mqtt message in byte
# Datatype: int
mqtt_max_message_size=1048576

Thanks in advance!