Influxdb adapter: storeState function

[Wladimir]

Hallo zusammen,

ich versuche die Funktion "storeState" im Script zu verwendet.

Der Code sieht so aus:

 sendTo('influxdb.0', 'storeState', {
     id: 'xxx',
      state: {ts: Date.now(),
            val: 2,
            ack: true,
            from: "yyy",
            q: 0
         }
  });

Leider bekomme ich immer folgenden Fehler:

influxdb.0	2018-11-06 19:11:57.435	error	at Socket.onpacket (/opt/iobroker/node_modules/iobroker.js-controller/node_modules/socket.io-client/lib/socket.js:236:12)
influxdb.0	2018-11-06 19:11:57.435	error	at Socket.onevent (/opt/iobroker/node_modules/iobroker.js-controller/node_modules/socket.io-client/lib/socket.js:278:10)
influxdb.0	2018-11-06 19:11:57.435	error	at Socket.Emitter.emit (/opt/iobroker/node_modules/iobroker.js-controller/node_modules/component-emitter/index.js:133:20)
influxdb.0	2018-11-06 19:11:57.435	error	at Socket. <anonymous>(/opt/iobroker/node_modules/iobroker.js-controller/lib/states/statesInMemClient.js:52:30)
influxdb.0	2018-11-06 19:11:57.435	error	at Object.change (/opt/iobroker/node_modules/iobroker.js-controller/lib/adapter.js:3400:34)
influxdb.0	2018-11-06 19:11:57.435	error	at Adapter.emit (events.js:211:7)
influxdb.0	2018-11-06 19:11:57.435	error	at emitOne (events.js:116:13)
influxdb.0	2018-11-06 19:11:57.435	error	at Adapter. <anonymous>(/opt/iobroker/node_modules/iobroker.influxdb/main.js:131:5)
influxdb.0	2018-11-06 19:11:57.435	error	at processMessage (/opt/iobroker/node_modules/iobroker.influxdb/main.js:310:9)
influxdb.0	2018-11-06 19:11:57.435	error	at storeState (/opt/iobroker/node_modules/iobroker.influxdb/main.js:1249:83)
influxdb.0	2018-11-06 19:11:57.435	error	TypeError: Cannot read property 'id' of undefined
influxdb.0	2018-11-06 19:11:57.435	error	message messagebox.system.adapter.influxdb.0 [object Object] Cannot read property 'id' of undefined</anonymous></anonymous> 

Hat das schon mal jemand von euch gemacht?

[apollon77]

Jupp, Bug gefunden.

Update mal von Github. geht es dann?

[Wladimir]

Es funktioniert. Danke!

[StefanRied]

@wladimir @apollon77
Hallo,

ich wollte auch gerade das gleiche machen und mit Influx Series arbeiten die NICHT als state in iobroker definiert sind.
Mit einem Script auf bestehende Daten zugreifen geht gut. Das Query findet Dinge in der Influx richtig.
Aber einen neuen Datenpunkt rein schreiben scheint nicht zu gehen.
Das landet nicht in der Datenbank.

sendTo('influxdb.0', 'storeState', {
     id: 'StromPreis2',
      state: {
          preis_brutto: 2,
          preis_netto: 3
         }
  });

sendTo('influxdb.0', 'query', 'select * from StromPreis2;', function (result) {
    if (result.error) {
        console.error(result.error);
    } else {
        // show result
        console.log('Rows: ' + JSON.stringify(result.result));
        
    }
});

Wenn ich storestate auf https://github.com/ioBroker/ioBroker.influxdb/blob/master/README.md richtig verstanden habe, kann ich doch damit auf states influx series schreiben, die in iobroker gar nicht definiert sind?

Oder muss ich mit dazu einen INSERT query zusammenbasteln und jeden wert einzeln schreiben?

Besten Dank

[apollon77]

@stefanried sagte in Influxdb adapter: storeState function:

Wenn ich storestate auf https://github.com/ioBroker/ioBroker.influxdb/blob/master/README.md richtig verstanden habe, kann ich doch damit auf states influx series schreiben, die in iobroker gar nicht definiert sind?

Ne das geht nicht. Der Adapter kennt nur States wo der InfluxDB-Adapter aktiviert ist.

[StefanRied]

@apollon77 Danke, dann muss man den Query insert nehmen.

[StefanRied]

@apollon77

Ich möchte einen Wert zu einer bestimmten Zeit einfügen.
Das Query geht von der Influx CLI, aber nicht aus dem Script. Sagt invalid call.
Auch \" geht nicht. Da hab ich noch einen Denkfehler?

sendTo('influxdb.0', 'query', 'INSERT StromPreis2 preis_brutto="42",preis_netto="32" 1635148170801249011;', function (result) {
    if (result.error) {
        console.error(result.error);
    } else {
        // show result
        console.log('Result: ' + JSON.stringify(result));
    }
});

[StefanRied]

Solved - Gelöst

Der iobroker influx Adapter scheint nicht wirklich zu helfen um irgend was in die Influx zu schreiben. Deshalb nutze ich jetzt direkt die Influx client lib. Das Beispiel schreibt zwei Records, ließt sie wieder und druckt sie aus. ...

const Influx = require('influx');
 const influx = new Influx.InfluxDB({
 host: '127.0.0.1',
 database: 'iobroker' 
 /* ,
 schema: [
   {
     measurement: 'StromPreis2',
     fields: {
       preis_brutto: Influx.FieldType.STRING,
       preis_netto: Influx.FieldType.STRING
     },
     tags: ['host']
   }
 ] */
});


influx.writePoints([  
    { measurement: 'StromPreis2', fields: { preis_brutto: '62', preis_netto: '52'}, timestamp : 1422568543702910257  },
    { measurement: 'StromPreis2', fields: { preis_brutto: '42', preis_netto: '32'}, timestamp : 1422568543702900250  }
]).then(() => {
  return influx.query(`select * from StromPreis2`) 
  }).then(rows => {
  rows.forEach(row => console.log(`Strompreis ${row.preis_brutto} / ${row.preis_netto}`))
})

Das Schema kann man explizit machen wie üblich.

PS: Das "influxdb" modul muss im Javascript Adapter unter "Zusätzliche NPM-Module" eingetragen sein.

[apollon77]

@stefanried Jupp das ist die bessere Lösung.

[Moppedman]

Hallo @apollon77 ,

ich habe ein ähnliche Frage und du scheinst dich mit dem Thema auszukennen. Ich habe auf meinen PI eine weitere mySQL Datenbank angelegt in der Bewertungen unsere Whiskygruppe abgelegt sind (CSV export aus Excel) . Auf die habe ich mit dem SQL Adapter zugegriffen und als JSON in einen Datenpunkt geschrieben zum Visualieren.

sendTo('sql.1', 'query', 'SELECT * FROM WhiskyTable.WhiskySingleMaltRanking', function (result) {
    if (result.error) {
        console.error(result.error);
    } else {
        // show result
         console.log('Rows: ' + JSON.stringify(result.result));
         setState("0_userdata.0.KOR-DatenPunkte.Whisky.Visu.WhiskyRanking",JSON.stringify(result.result));
        // let WhiskyDaten ('Rows: ' + JSON.stringify(result.result));
    }
})

Nun will ich in Zukunft das wir die Tasting-Bewertungen auf meiner WEB Site eingeben und diese mit in die Datenbank geschrieben werden.

Kann es sein das ich mit dem SQL Adapter und dem Befehl storeState auf diese Externe DB nicht schreiben kann sondern nur die dem ioBroker bekannte SQL DB? Zumindest habe ich bisher da nicht reinschreiben können.

Kannst du mir bei Gelegenheit einen Tip geben ob das geht?

Wenn nicht wäre das mysqljs eine Alternative ?

Bin allerdings recht neu in dem Thema SQL.