Simple Log Service:PostgreSQL プロトコルを使用した Simple Log Service への接続

PostgreSQL クライアントを使用して SLS に接続するには、次の URL 形式を使用します。

postgresql://{AccessKey_ID}:{AccessKey_Secret}@{Endpoint}:5432/{Project_Name}
# 接続では TLS がデフォルトで有効化されています（認証方式は MD5）。TLS を明示的に無効化する場合（たとえばクライアントが TLS をサポートしていない場合）、sslmode パラメーターを disable に設定します。
postgresql://{AccessKey_ID}:{AccessKey_Secret}@{Endpoint}:5432/{Project_Name}?sslmode=disable

JDBC を介して PostgreSQL プロトコルで SLS に接続するには、次の構成を使用します。

private static final String URL = "jdbc:postgresql://{Endpoint}:5432/{Project_Name}?preferQueryMode=simple";
private static final String AccessKey_ID = "xyz";
private static final String AccessKey_Secret = "123456";

public static void main(String[] args) throws Exception
{
    Properties props = new Properties();
    props.setProperty(PGProperty.USER.getName(), AccessKey_ID);
    props.setProperty(PGProperty.PASSWORD.getName(), AccessKey_Secret);

    try (Connection conn = DriverManager.getConnection(URL, props)) {
        System.out.println("接続に成功しました！");
    }
}

パラメーターの説明：

テーブルの作成

CREATE TABLE ステートメントを使用してログストアを作成します。

CREATE TABLE users (
    id           BIGINT,
    name         TEXT,
    create_time  TIMESTAMP
)
WITH (
    shard_count = 4,
    ttl = 14,
    default_query_range = '1d',
    full_text_search_enabled = true,

    index_tokens = '&[ ]",''\',

    log_time_field = 'create_time',
    insert_any_allowed = false
);

サポートされるカラム型：

テーブルプロパティ（WITH 句）：

カラムの変更

以下のカラム変更操作がサポートされています。

カラムの追加：

ALTER TABLE users ADD COLUMN change_time TEXT;

カラム名の変更：

ALTER TABLE users RENAME COLUMN change_time TO update_time;

カラム型の変更：

ALTER TABLE users ALTER COLUMN update_time TYPE TIMESTAMP;

カラムの削除：

ALTER TABLE users DROP COLUMN update_time;

データのクリア

TRUNCATE ステートメントを使用してテーブル内のすべてのデータをクリアします。

TRUNCATE TABLE users;

注：データが削除された後、SQL クエリで変更が反映されるまで約 30 秒かかります。

テーブルの削除

DROP TABLE ステートメントを使用してテーブルを削除します（対応するログストアも削除されます）。

DROP TABLE users;

基本的なクエリ

標準の SQL SELECT ステートメントを使用してデータをクエリします。

SELECT id, name FROM users LIMIT 10;

注：SQL ステートメント内で時間範囲が指定されていない場合、default_query_range で定義されたデフォルトの時間範囲が使用されます。テーブル作成時に default_query_range が設定されていない場合、クエリは直近 15 分間のデータをデフォルトで対象とします。

クエリ時間範囲の指定

以下のいずれかの方法でクエリ時間範囲を指定します。

-- 時間範囲の下限を指定
SELECT id, name FROM users 
WHERE __time__ > 1766646000
LIMIT 10;

-- 時間範囲を指定
SELECT id, name FROM users 
WHERE __time__ > 1766646000 AND __time__ < 1766646987
LIMIT 10;

-- 時間範囲の下限を設定
SET query_begin = 1766646000; 
SELECT id, name FROM users LIMIT 10;

-- 時間範囲を設定
SET query_begin = 1766646000; 
SET query_end = 1766646987; 
SELECT id, name FROM users LIMIT 10;

-- 単一のステートメントで変数を設定（推奨）
SET query_begin = 1766646000; SET query_end = 1766646987; SELECT id, name FROM users LIMIT 10;

基本的な書き込み

INSERT INTO ステートメントを使用してデータを書き込みます。

INSERT INTO users (id, name, create_time) 
VALUES
    (1, 'Name#1', '2025-12-25T06:54:19'),
    (2, 'Name#2', '2025-12-25T06:54:20'),
    (3, 'Name#3', '2025-12-25T06:54:21');

EXACTLY-ONCE 書き込み

SLS の PostgreSQL プロトコルは、プライマリキーなどの一意性制約をサポートしていませんが、データが 1 度だけ書き込まれることを保証する EXACTLY-ONCE 書き込みをサポートしています。

hash_key および seq_id 変数を使用して EXACTLY-ONCE 書き込みを実装します。

SET hash_key = 'file#1'; 
SET seq_id = 1; 
INSERT INTO users (id, name, create_time) 
VALUES
    (1, 'Name#1', '2025-12-25T06:54:19'),
    (2, 'Name#2', '2025-12-25T06:54:20'),
    (3, 'Name#3', '2025-12-25T06:54:21');

パラメーターの説明：

重複データのエラー処理：

重複データが書き込まれた場合、サーバーは以下の形式でエラーメッセージを返します。

error: sequence id is lower than expected, hash_key=xyz,current sequence_id=100,requested sequence_id=90

サーバーの応答から現在の seq_id を抽出するには、以下の正規表現を使用します。

current\s+sequence_id=(\d+)

すべてのログストアのクエリ

SELECT 
    table_schema, 
    table_name
FROM 
    information_schema.tables;

注：デフォルトでは、ログストアは同名のプロジェクト内のスキーマにマップされます。

フィールド構造のクエリ

SELECT 
    column_name, 
    data_type
FROM 
    information_schema.columns 
WHERE 
    table_name = 'access_log';