Блог

У меня есть csv-файл, и мне нужно отправить этот файл в виде сообщения MQTT, но мне нужно, чтобы он отправлялся только одной строкой с перерывом в несколько секунд, а затем следующей строкой и снова перерывом в несколько секунд. Это что-то вроде моделирования датчика, но с данными в файле csv. Я пытался решить это несколькими различными способами, но ничего не получалось. Я пишу на Python. Спасибо вам, ребята, за любую помощь. Код здесь — моя последняя попытка, и после запуска функции MQTT_publish() я получаю сообщения с перерывом в 5 секунд, но в каждом сообщении содержится целый файл, а не только одна строка. Я действительно не знаю, что с этим делать.

 def MQTT_publish(broker, file, topic):
  client = mqtt.Client()
  print("Connecting to broker", broker)
  client.connect(broker)
  client.loop_start()
  print("Publishing...")

  client.loop_start()
  with open(file, 'r') as read_obj:
      data = reader(read_obj)
      for row in data:
          client.publish(f"{topic}", str(row))
          time.sleep(5)
  client.loop_stop()

def on_message(client, userdata, message):
  print(str(message.payload.decode("utf-8")))


def MQTT_subscribe(broker, topic):
  client = mqtt.Client()
  print("Connecting to broker", broker)
  client.connect(broker)

  print(f"Subscribing {topic}")
  client.subscribe(f"{topic}")
  client.on_message = on_message
  client.loop_forever()

broker = "mqtt.eclipse.org"
 

Разве вы не должны использовать readlines()??

 myfile = open(file, 'r')
Lines = myfile.readline()
for line in Lines:
  client.publish(f"{topic}", str(line.strip()))
  time.sleep(5)
 

Предполагается, что данные в файле представлены в формате ASCII с переводом строки.