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.

apollon77

@moppedman sagte in Influxdb adapter: storeState function:

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.

Korrekt. schreiben geht im SQL Adapter nur wenn die States aktiviert sind.

Moppedman

Danke @apollon77 für die Bestätigung das es so nicht geht.

Hast du eine Empfehlung wie ich nun am einfachsten Daten in die externe DB geschrieben kriege?

Ralf

apollon77

@moppedman es gibt aktuell nichts als Adapter was freie Daten schreiben kann. Also mach ein JavaScript und nutze eine Library und mach’s darüber. Habe gerade keine andere Lösung.

Kannst im sql Adapter ein enhancement ticket auf machen das wir freuen Datenzugriff Ala crud auf ne DB einbauen … ist aber garantiert nix was morgen fertig ist

Moppedman

Hi @apollon77

habe mir das jetzt in JS aufgebaut und das Schreiben und Lesen funktioniert einwandfrei. Daher werde ich kein Ticket aufmachen denn das was ich habe reicht mir.

Habe noch ein Problem bei dem ich die Durchschnittsberechnung AVG von mySQL verwenden wollte. Bei der Abfrage

function CalcAverage(){
        db.query('SELECT AVG(Punktzahl), AVG(Cremig), AVG(Kraeuter)  FROM WhiskyTable.Voting WHERE DatumTasting = ?  AND WhiskyNr = ? AND TeamMember != ?' ,
            [dp_DateConsolidate, dp_WhiskyNrConsolidate, dp_Nasenfaktor] ,
            function (error,result,fields) {

            if(error)  {
                throw error;

            } else {

                console.log(result)   
                
                console.log (" bist du ein Array ?? " + Array.isArray(result)) 
                                      
                const AVG_result = JSON.stringify(result);
                console.log (" Variable AVG_result 1111==>" + AVG_result)

                const Test2 = JSON.parse(AVG_result);
                console.log (" Variable AVG_result 2222==>" + Test2)
            
                     
               let AVG_result_0 = (result[0])
                console.log (" Variable AVG_result_0 3333==>" + AVG_result_0)

bekomme ich folgende Ergebnisse zurück

Ich will aus dem Array in der ersten Zeile z.b. auf 'AVG(Cremig)' zugreifen und den Wert 0.35 der dort steht einer Variablen zuweisen

Bei einer normal QUERY SELECT * FROM xxxxx

Kann ich mit console.log(result[X].Cremig) gezielt den Datensatzeintrag X ansprechen und auch einer Variablen zuweisen.

Beim AVG Array aber scheint es das Problem zu sein das das 'AVG(Cremig)' Klammern hat die ich weder in der console.log noch beim VAriablen zuweisen verwenden kann.

Wie du siehst habe ich verschiede Tests gemacht aber eine Lösung bis jetzt nicht gefunden. Eine Idee wie ich das in JS lösen kann

Ralf

apollon77

@moppedman Dann gib ihm nen normalen namen?

SELECT AVG(Punktzahl) as avg_punktzahl, ....

Geht das? ALso bei normal SQL sollte das tun ... InfluxQL bzw FluxQL müsste man schauen aber geht bestimmt auch

Moppedman

@apollon77

Super, das funktioniert !!! Danke für die schnelle Hilfe

NEWS

Influxdb adapter: storeState function

Support us

833
Online

30.5k
Users

76.8k
Topics

1.2m
Posts

NEWS

Influxdb adapter: storeState function

Support us

833Online

30.5kUsers

76.8kTopics

1.2mPosts

833
Online

30.5k
Users

76.8k
Topics

1.2m
Posts