java 存储数据到influxdb demo

在 Java 中将数据存储到 InfluxDB（一种分布式、时间序列数据库）通常需要使用官方提供的 InfluxDB Java客户端库。以下是一个简单的示例，演示如何连接到 InfluxDB、创建数据库、表以及插入一条数据：

首先，你需要添加 InfluxDB Java Client 的依赖到你的项目中，如果你使用的是 Maven，可以在 `pom.xml` 文件里添加：

<dependency>
    <groupId>com.influxdata</groupId>
    <artifactId>influxdb-java</artifactId>
    <version>2.27.0</version> <!-- 更新至最新版本 -->
</dependency>

接下来，你可以按照以下步骤操作：

import com.influxdb.InfluxDB;
import com.influxdb.client.InfluxDBClient;
import com.influxdb.client.WriteApi;
import com.influxdb.model.BatchPoints;
import com.influxdb.query.Result;

public class InfluxDataExample {
    public static void main(String[] args) throws Exception {
        // 连接配置
        String url = "http://localhost:8086"; // InfluxDB服务器地址
        String username = "your_username";
        String password = "your_password";
        String database = "my_database";

        // 创建InfluxDB客户端
        InfluxDBClient client = InfluxDBClient.create(url, username, password);

        try {
            // 打开写入API
            WriteApi writeApi = client.writeApi();

            // 创建批点 (Batch Points)
            BatchPoints batchPoints = BatchPoints
                    .database(database)
                    .retentionPolicy("default") // 默认持久化策略
                    .record(
                            Point.measurement("cpu_usage")
                                    .tag("host", "server1")
                                    .field("usage", 50)
                                    .time(System.currentTimeMillis(), ChronoUnit.SECONDS)); // 插入数据

            // 写入数据
            writeApi.write(batchPoints.build());

            System.out.println("Data written successfully.");
        } finally {
            // 关闭连接
            client.close();
        }
    }
}

这个示例假设你已经在本地运行了 InfluxDB 服务，并且用户名和密码已设置。记得替换 `url`, `username`, 和 `password` 为你实际的环境值。