First version of mqtt support.

[mbehr1]

See here for #308 the first commits for review and discussion.
Seems to work for me.

Topics generated are:
< prefix>/chn/id <- contains the channel identifier (e.g. Obis code)
< prefix>/chn/uuid <- contains the uuid from that channel
< prefix>/chn/[raw|agg] <- contains the last value. either raw or from configured agg mode.
prefix defaults to "vzlogger" and can be overwritten in mqtt object within vzlogger.conf.

For testing I used test.mosquitto.org. Simply update mqtt object inside vzlogger.cfg and e.g. use mosquitto_sub -h test.mosquitto.org -t "vzlogger/#" -v
and see the data arriving ;-)

[andig]

Hi Mathias,

Code ist jenseits meiner Fähigkeiten ;) Was ich nich gesehen habe: reconnect wenn mqtt stirbt und wieder kommt bzw. late connect falls mqtt meim Start von vzlogger nicht da? Namenskonvention der Topics?

Viele Grüße, Andreas

[mbehr1]

@andig reconnect ist dabei:
int res = mosquitto_loop(mqttClient->_mcs, 1000, 1); if (res != MOSQ_ERR_SUCCESS) { print(log_warning, "mosquitto_loop returned %d. trying reconnect", "mqtt", res); sleep(1); res = mosquitto_reconnect(mqttClient->_mcs);
gleiches sollte auch den late connect abhandeln.
Aber wäre gut, wenn das von paar Leuten mit getestet werden kann. Habe bei log_finest relativ viele Log Ausgaben. Könnte schnell noch was einbauen.

[andig]

Ich hab den Logger gar nicht mehr im Einsatz- Modbus Zähler...

[mbehr1]

Hab reconnect Handling beim Startup hinzugefügt. Wenn "con refused" kommt, wird später wieder versucht.

[andig]

Wie heissen die Topics?

[mbehr1]

s.o.
< prefix>/chn/id <- contains the channel identifier (e.g. Obis code)
< prefix>/chn/uuid <- contains the uuid from that channel
< prefix>/chn/[raw|agg] <- contains the last value. either raw or from configured agg mode.
prefix defaults to "vzlogger" and can be overwritten in mqtt object within vzlogger.conf.
also. z.b.
"vzlogger/chn5/id"
"vzlogger/chn5/uuid"
"vzlogger/chn5/agg"

[mbehr1]

I could add the meter name as well into the topic. e.g. vzlogger/mtr1/chn5/... but the channel ids would still be unique. (so e.g. mtr1/ch1, mtr1/ch2, mtr2/ch3,...)

[andig]

"vzlogger/chn5/id"

Wo kommt denn das chn5 her- manuell zu konfigurieren? Oder beim Startup durchnummeriert?

"vzlogger/chn5/uuid"

Uuid optional? Im use case von @gitka würde es ja gar kein VZ api mehr geben.

Ich habe bei meinen Redesigngedankenspielen auch damit gekämpft wie die Hierarchie aus Meter/ Devices/ Meßwerten aussehen soll. Richtig glücklich hat mich am Ende nicht gemacht...

[mbehr1]

Wo kommt denn das chn5 her- manuell zu konfigurieren? Oder beim Startup durchnummeriert?

ist der 5. Channel aus der Cfg. Ich nutze einfach Channel::name().
Für uuid nutze ich Channel::uuid(). Habe grad noch Commit hinzugefügt, der die nur nutzt, wenn nicht leer.

[tunip]

Runs quite good so far.

[sir106]

when will this be merged into the master branch ? long awaited feature ;)

[mbehr1]

@andig ok for you to be merged?

[andig]

Yes of course! And prerequisite for #366

[r00t-]

@mbehr1:
great that you supplied this code!
but can you comment on why you integrated it into the core in the way you did?
(i imagine there are some challenges in implementing it "properly", and it would be great if you could provide information on them to anybody looking to improve the integration.)
either here or in #550.