当OT遇见IT：Apache IoTDB如何用“时序空间一体化“技术破解工业物联网数据孤岛困局？

java -version

wget https://downloads.apache.org/iotdb/2.5.0/apache-iotdb-2.5.0-all-bin.zip

unzip apache-iotdb-2.5.0-all-bin.zip -d /opt/iotdb

export IOTDB_HOME=/opt/iotdb/apache-iotdb-2.5.0-all-bin
export PATH=$PATH:$IOTDB_HOME/sbin:$IOTDB_HOME/bin

source ~/.bashrc

cd /opt/iotdb/apache-iotdb-2.5.0-all-bin/sbin
./start-server.sh

cd /opt/iotdb/apache-iotdb-2.5.0-all-bin/sbin
./start-cli.sh -h 127.0.0.1 -p 6667 -u root -pw root

-- 使用 root 用户登录
./sbin/start-cli.sh -h 127.0.0.1 -p 6667 -u root -pw root

-- 创建新用户
CREATE USER 'newuser' 'newpassword';

-- 查看所有用户
SHOW USERS;

-- 授予读取权限
GRANT READ ON root.ln.wf01 TO 'newuser';

-- 授予写入权限
GRANT WRITE ON root.ln.wf01 TO 'newuser';

-- 授予管理员权限
GRANT ADMIN TO 'newuser';

-- 修改密码
ALTER USER 'newuser' SET PASSWORD 'newpassword';

-- 删除用户
DROP USER 'newuser';

# 生成私钥
openssl genrsa -out server.key 2048

# 生成证书签名请求 (CSR)
openssl req -new -key server.key -out server.csr

# 生成自签名证书
openssl x509 -req -days 365 -in server.csr -signkey server.key -out server.crt

# 启用 SSL
enable_ssl=true

# 指定证书和私钥路径
ssl_key_file=/path/to/server.key
ssl_cert_file=/path/to/server.crt

./sbin/start-cli.sh -h 127.0.0.1 -p 6667 -u root -pw root --use-ssl

# 开启审计日志
enable_audit_log=true

# 设置审计日志文件路径
audit_log_dir=/path/to/audit/logs

cat /path/to/audit/logs/audit.log

# 备份当前数据库
./sbin/backup.sh -d /path/to/backup/dir

# 恢复数据库
./sbin/restore.sh -d /path/to/backup/dir

# 检查当前版本
./sbin/start-cli.sh -h 127.0.0.1 -p 6667 -u root -pw root -e "SHOW VERSION;"

# 下载最新版本
wget https://iotdb.apache.org/zh/Download/

# 使用 Prometheus 和 Grafana 监控 IoTDB
# 配置 Prometheus 抓取 IoTDB 指标
scrape_configs:
  - job_name: 'iotdb'
    static_configs:
      - targets: ['localhost:6667']

# 在 iotdb-engine.properties 中配置白名单
whitelist=192.168.1.0/24,127.0.0.1

CREATE TIMESERIES root.ln.wf01.wt01.status WITH DATATYPE=BOOLEAN, ENCODING=PLAIN;
CREATE TIMESERIES root.ln.wf01.wt01.temperature WITH DATATYPE=FLOAT, ENCODING=RLE;

INSERT INTO root.ln.wf01.wt01(timestamp,status,temperature) values(1,true,25.96);
INSERT INTO root.ln.wf01.wt01(timestamp,status,temperature) values(2,false,24.3);
INSERT INTO root.ln.wf01.wt01(timestamp,status,temperature) values(3,true,26.1);

SELECT * FROM root.ln.wf01.wt01 WHERE time >= 1 AND time <= 3;

+-----------------------------+------------------------+-------------------------+
|                         Time|root.ln.wf01.wt01.status|root.ln.wf01.wt01.temperature|
+-----------------------------+------------------------+-------------------------+
|1970-01-01T08:00:00.001+08:00|                    true|                     25.96|
|1970-01-01T08:00:00.002+08:00|                   false|                      24.3|
|1970-01-01T08:00:00.003+08:00|                    true|                      26.1|
+-----------------------------+------------------------+-------------------------+

SELECT AVG(temperature) FROM root.ln.wf01.wt01 WHERE time >= 1 AND time <= 3;

+-----------------------------+-------------------------+
|                         Time|AVG(root.ln.wf01.wt01.temperature)|
+-----------------------------+-------------------------+
|                         null|                     25.453333333333334|
+-----------------------------+-------------------------+

cd /opt/iotdb/apache-iotdb-2.5.0-all-bin/sbin
./stop-server.sh

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;

public class IoTDBExample {
    public static void main(String[] args) throws Exception {
        // 建立连接
        Connection connection = DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
        Statement statement = connection.createStatement();

        // 创建时间序列
        statement.execute("CREATE TIMESERIES root.ln.wf01.wt01.temperature WITH DATATYPE=FLOAT, ENCODING=RLE");

        // 插入数据
        statement.execute("INSERT INTO root.ln.wf01.wt01(timestamp, temperature) VALUES (now(), 25.3)");

        // 关闭连接
        connection.close();
    }
}

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;

public class IoTDBBatchInsertExample {
    public static void main(String[] args) throws Exception {
        // 建立连接
        Connection connection = DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
        PreparedStatement preparedStatement = connection.prepareStatement(
            "INSERT INTO root.ln.wf01.wt01(timestamp, temperature) VALUES (?, ?)"
        );

        // 批量插入数据
        for (int i = 0; i < 1000000; i++) {
            preparedStatement.setLong(1, System.currentTimeMillis());
            preparedStatement.setFloat(2, 25.3f + i * 0.1f);
            preparedStatement.addBatch();
        }

        // 执行批处理
        preparedStatement.executeBatch();

        // 关闭连接
        connection.close();
    }
}

-- 查询数据
SELECT * FROM root.ln.wf01.wt01 WHERE time >= 1 AND time <= 3;

-- 创建树模型时间序列
CREATE TIMESERIES root.device.sensor1.temperature WITH DATATYPE=FLOAT, ENCODING=RLE;

-- 创建表模型时间序列
CREATE TABLE root.device.sensor1 (time TIMESTAMP, temperature FLOAT);

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;

public class IoTDBHighFrequencyInsertExample {
    public static void main(String[] args) throws Exception {
        // 建立连接
        Connection connection = DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
        PreparedStatement preparedStatement = connection.prepareStatement(
            "INSERT INTO root.ln.wf01.wt01(timestamp, temperature) VALUES (?, ?)"
        );

        // 批量插入数据
        for (int i = 0; i < 1000000; i++) {
            preparedStatement.setLong(1, System.currentTimeMillis());
            preparedStatement.setFloat(2, 25.3f + i * 0.1f);
            preparedStatement.addBatch();
        }

        // 执行批处理
        preparedStatement.executeBatch();

        // 关闭连接
        connection.close();
    }
}

-- 使用 UDF 函数进行数据分析
SELECT AVG(temperature), MIN(temperature), MAX(temperature) 
FROM root.ln.wf01.wt01 
WHERE time >= '2023-01-01T00:00:00' AND time <= '2023-01-01T23:59:59';

<dependency>
    <groupId>org.apache.iotdb</groupId>
    <artifactId>iotdb-session</artifactId>
    <version>1.3.0</version>
</dependency>

import org.apache.iotdb.session.Session;
import org.apache.iotdb.tsfile.file.metadata.enums.CompressionType;
import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;

import java.util.ArrayList;
import java.util.List;

public class IoTDBExample {
    public static void main(String[] args) throws Exception {
        // 建立连接
        Session session = new Session("127.0.0.1", 6667, "root", "root");
        session.open();

        // 创建数据库
        session.executeNonQueryStatement("CREATE DATABASE IF NOT EXISTS root.vehicle");

        // 创建时间序列
        List<MeasurementSchema> schemaList = new ArrayList<>();
        schemaList.add(new MeasurementSchema("speed", TSDataType.INT32, TSEncoding.RLE, CompressionType.SNAPPY));
        schemaList.add(new MeasurementSchema("temperature", TSDataType.FLOAT, TSEncoding.PLAIN, CompressionType.SNAPPY));
        session.createTimeseries("root.vehicle.car01", schemaList);

        // 插入数据
        session.insertRecord("root.vehicle.car01", 1717027200000L, new Object[]{120, 25.5f});
        session.insertRecord("root.vehicle.car01", 1717027260000L, new Object[]{130, 26.0f});

        // 查询数据
        String sql = "SELECT * FROM root.vehicle.car01";
        var dataset = session.executeQueryStatement(sql);
        while (dataset.hasNext()) {
            System.out.println(dataset.next());
        }

        // 关闭连接
        session.close();
    }
}

1717027200000, root.vehicle.car01.speed=120
1717027200000, root.vehicle.car01.temperature=25.5
1717027260000, root.vehicle.car01.speed=130
1717027260000, root.vehicle.car01.temperature=26.0