How To Get Dataframe In Structured Streaming?

I want to receive JSON strings from MQTT and parse them to DataFrames df. How can I do it? This is an example of Json message that I send to MQTT queue in order to process in Spark

Solution 1:

I guess it is because your df is not streaming.How about try just reader.select("value").writestream