InfluxDB Client

Hallo allerseits.

Zur zeit habe ich ein kleines PHP Programm am laufen, das mir Daten die von einem LORA WAN Sensor kommen, in eine MongoDB schreibt,

Hier mal mein PHP Programm:

<?php

$ttn_post = file('php://input');  
$data = json_decode($ttn_post);

$server_datetime = date("Y-m-d H:i:s");  

    // connect to mongodb
$manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');  
//var_dump($manager);

 $bulkWrite = new MongoDB\Driver\BulkWrite;
 $doc = [$server_datetime,$data];

$bulkWrite->insert($doc);
$manager->executeBulkWrite('admin.lorawan', $bulkWrite);  

?>

Das selbe möchte ich jetzt für InfluxDB erstellen.
Hab ich getan, soweit ich die Doku verstanden habe.

<?php

use InfluxDB2\Client;
use InfluxDB2\Model\WritePrecision;
use InfluxDB2\Point;

$ttn_post = file('php://input');  
$data = json_decode($ttn_post);

$server_datetime = date("Y-m-d H:i:s");  

 $doc = [$server_datetime,$data];

 $bucket ="lorawan";  
 $org = "meine org";  

 $client = new InfluxDB2\Client([
    "url" => "http://2.206.223.165:8086",  
    "token" => "mein token",  
    "bucket" => "lorawan",  
    "org" => "meine org",  
    "precision" => InfluxDB2\Model\WritePrecision::NS  

  ]);

       $writeApi->write($doc, WritePrecision::S, $bucket, $org);

?>

Leider funktioniert das nicht.
Jetzt erhoffe ich mir etwas Hilfe von euch.

Hat jemand Lust mir dabei helfen?

Bitte markiere auch die Kommentare, die zur Lösung des Beitrags beigetragen haben

Content-ID: 4895610674

Url: https://administrator.de/contentid/4895610674

Ausgedruckt am: 21.11.2024 um 18:11 Uhr

1 Kommentar

Wenn du mit der Variable "$client" ein "new InfluxDB2\Client" machst, solltest du auch mit der "$client" Variable weiter arbeiten und nicht auf die Variable "$writeApi" wechseln.

$client = new InfluxDB2\Client([
    "url" => "http://2.206.223.165:8086",  
    "token" => "mein token",  
    "bucket" => "lorawan",  
    "org" => "meine org",  
    "precision" => InfluxDB2\Model\WritePrecision::NS  
]);
$client->write($doc, WritePrecision::S, $bucket, $org);