69 lines
1.7 KiB
PHP
69 lines
1.7 KiB
PHP
<?php
|
|
/**
|
|
* Shows how to delete data from InfluxDB by client
|
|
*/
|
|
|
|
require __DIR__ . '/../vendor/autoload.php';
|
|
|
|
use InfluxDB2\Client;
|
|
use InfluxDB2\Model\DeletePredicateRequest;
|
|
use InfluxDB2\Point;
|
|
use InfluxDB2\Service\DeleteService;
|
|
|
|
$url = 'http://localhost:8086';
|
|
$token = 'my-token';
|
|
$org = 'my-org';
|
|
$bucket = 'my-bucket';
|
|
|
|
$client = new Client([
|
|
"url" => $url,
|
|
"token" => $token,
|
|
"bucket" => $bucket,
|
|
"org" => $org,
|
|
"precision" => InfluxDB2\Model\WritePrecision::S
|
|
]);
|
|
|
|
//
|
|
// Write data into InfluxDB
|
|
//
|
|
$writeApi = $client->createWriteApi();
|
|
$point1 = Point::measurement("mem")
|
|
->addTag("host", "host1")
|
|
->addField("used_percent", 24.43234543);
|
|
$point2 = Point::measurement("mem")
|
|
->addTag("host", "host2")
|
|
->addField("used_percent", 54.43234543);
|
|
$writeApi->write(array($point1, $point2));
|
|
$writeApi->close();
|
|
|
|
//
|
|
// Delete data by tag value: 'host = host2'
|
|
//
|
|
/** @var DeleteService $service */
|
|
$service = $client->createService(DeleteService::class);
|
|
|
|
$predicate = new DeletePredicateRequest();
|
|
$predicate->setStart(DateTime::createFromFormat('Y', '2020'));
|
|
$predicate->setStop(new DateTime());
|
|
$predicate->setPredicate("_measurement=\"mem\" AND host=\"host1\"");
|
|
$service->postDelete($predicate, null, $org, $bucket);
|
|
|
|
//
|
|
// Query Data
|
|
//
|
|
$queryApi = $client->createQueryApi();
|
|
$query = "from(bucket: \"{$bucket}\") |> range(start: -1h)";
|
|
$tables = $queryApi->query($query);
|
|
|
|
foreach ($tables as $table) {
|
|
foreach ($table->records as $record) {
|
|
$time = $record->getTime();
|
|
$measurement = $record->getMeasurement();
|
|
$value = $record->getValue();
|
|
$host = $record->values["host"];
|
|
print "$time $measurement is $value for host: $host\n";
|
|
}
|
|
}
|
|
|
|
$client->close();
|