influxdb 1.x 在java中如何用builder插入数据?
时间: 2024-04-21 18:22:15 浏览: 85
在 InfluxDB 1.x 的 Java 客户端库中,可以使用 Point.Builder 类来构建数据点并插入数据。下面是使用 Builder 模式插入数据的示例代码:
```java
import org.influxdb.InfluxDB;
import org.influxdb.InfluxDBFactory;
import org.influxdb.dto.Point;
import java.util.concurrent.TimeUnit;
public class InfluxDBExample {
public static void main(String[] args) {
// 连接到 InfluxDB
String url = "http://localhost:8086";
String username = "your_username";
String password = "your_password";
String database = "your_database";
InfluxDB influxDB = InfluxDBFactory.connect(url, username, password);
// 创建数据库(如果不存在)
influxDB.createDatabase(database);
influxDB.setDatabase(database);
// 创建数据点并插入数据
String measurement = "measurement_name";
Point.Builder pointBuilder = Point.measurement(measurement)
.time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
.addField("field1", 10)
.addField("field2", 20);
Point point = pointBuilder.build();
influxDB.write(point);
// 关闭连接
influxDB.close();
}
}
```
在上述示例中,你可以使用 Point.Builder 类来构建数据点。你可以连续调用 builder 对象的方法来设置测量名称、时间戳和字段值。最后,通过调用 `pointBuilder.build()` 方法来构建 `Point` 对象,并使用 `influxDB.write(point)` 方法将数据点插入到数据库中。
请确保在运行代码之前,你已经正确地配置和运行了 InfluxDB 1.x 数据库,并且已经添加了 InfluxDB Java 客户端库的依赖。
阅读全文