Java を使用して Cassandra ベースの時系列データベース アプリケーションを開発する方法

Java を使用して Cassandra ベースの時系列データベース アプリケーションを開発する方法

時系列データとは、センサー データやログ データなど、時間の経過とともに生成される順序付けされたデータを指します。 、など。モノのインターネットとビッグデータの発展に伴い、時系列データの保存と分析の需要も高まっています。

Cassandra は、高いパフォーマンスと高可用性を備えた拡張性の高い分散データベース システムであり、時系列データの保存に最適です。この記事では、Java を使用して Cassandra ベースの時系列データベース アプリケーションを開発する方法を紹介します。

ステップ 1: Cassandra のインストールと構成

まず、Cassandra をインストールして構成する必要があります。 Cassandra の最新バージョンを公式 Cassandra Web サイトからダウンロードし、公式ドキュメントのガイドラインに従ってインストールおよび設定できます。

インストールが完了したら、Cassandra サービスを開始します。

ステップ 2: Cassandra テーブルを作成する

Cassandra では、データはテーブルの形式で編成および保存されます。時系列データを保存するには、タイムスタンプと値の 2 つの列を含むテーブルを作成する必要があります。

CQL (Cassandra Query Language) を使用してテーブルを作成できます。 CQL シェル (cqlsh) を開き、次のコマンドを使用してテーブルを作成します。

CREATE KEYSPACE IF NOT EXISTS my_keyspace WITH REPLICATION = {'class': 'SimpleStrategy', 'replication_factor': 1};
USE my_keyspace;

CREATE TABLE IF NOT EXISTS time_series_data (
    sensor_id UUID,
    timestamp TIMESTAMP,
    value DOUBLE,
    PRIMARY KEY (sensor_id, timestamp)
)
WITH CLUSTERING ORDER BY (timestamp DESC);

上記のコマンドは、my_keyspace という名前のキースペースを作成し、その中に time_series_data# という名前のキースペースを作成します。 ＃＃ テーブル。 sensor_id はセンサーの一意の識別子、timestamp はデータ ポイントのタイムスタンプ、value はデータ ポイントの値です。 PRIMARY KEY はテーブルの主キーを指定します。sensor_id はパーティション キーとして使用され、timestamp はクラスタリング キーとして使用され、降順で並べ替えられます。注文。

ステップ 3: Cassandra Java ドライバーをインポートする

Java を使用して Cassandra アプリケーションを開発するには、Cassandra Java ドライバーをインポートする必要があります。次の依存関係を追加することでドライバーをインポートできます。

<dependency>
    <groupId>com.datastax.oss</groupId>
    <artifactId>java-driver-core</artifactId>
    <version>4.13.1</version>
</dependency>

上記の依存関係をプロジェクトの

pom.xml ファイルに追加し、プロジェクトの依存関係を更新します。

ステップ 4: Java コードを作成する

Java で Cassandra と対話するには、Cassandra Java ドライバーを使用する必要があります。以下は、Java を使用して Cassandra ベースの時系列データベース アプリケーションを開発する方法を示すサンプル コード スニペットです:

import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.CqlSessionBuilder;

public class CassandraTimeSeriesApp {
    public static void main(String[] args) {
        try (CqlSession session = new CqlSessionBuilder().build()) {
            // 建立Cassandra会话
            
            // 插入数据
            session.execute("INSERT INTO my_keyspace.time_series_data (sensor_id, timestamp, value) VALUES (?, ?, ?)",
                    UUID.randomUUID(), Instant.now(), 25.0);

            // 查询数据
            ResultSet resultSet = session.execute("SELECT * FROM my_keyspace.time_series_data WHERE sensor_id=? LIMIT 10",
                    UUID.randomUUID());
            
            // 处理查询结果
            for (Row row : resultSet) {
                UUID sensorId = row.getUuid("sensor_id");
                Instant timestamp = row.getInstant("timestamp");
                double value = row.getDouble("value");
                
                // 处理数据
                System.out.printf("sensorId=%s, timestamp=%s, value=%f%n", sensorId, timestamp, value);
            }
        }
    }
}

上記のコード スニペットは、最初に Cassandra とのセッション (

CqlSession) を確立します。 。次に、CQL ステートメントを実行してテーブルにデータを挿入し、CQL クエリ ステートメントを使用してデータをクエリします。最後に、クエリ結果を反復処理してデータを処理します。

ステップ 5: アプリケーションの実行

IDE で上記のコードを実行し、Java コードを通じて Cassandra と対話します。

対応する Cassandra サービスが開始されていること、およびコードを実行しているシステムに Cassandra ドライバーが正しくインストールされていることを確認する必要があります。

概要

この記事では、Java を使用して Cassandra ベースの時系列データベース アプリケーションを開発する方法を紹介します。まず、Cassandra をインストールして構成します。次に、時系列データを保存するテーブルを作成します。次に、Cassandra Java ドライバーをインポートし、Cassandra と対話する Java コードを作成します。最後に、アプリケーションを実行してクエリ結果を処理します。

この記事が、Java を使用して Cassandra ベースの時系列データベース アプリケーションを開発する方法を理解するのに役立つことを願っています。

以上がJava を使用して Cassandra ベースの時系列データベース アプリケーションを開発する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。