Simple Log Service:Koneksi ke SLS menggunakan protokol PostgreSQL

Untuk terhubung ke SLS menggunakan client PostgreSQL, gunakan format URL berikut:

postgresql://{AccessKey_ID}:{AccessKey_Secret}@{Endpoint}:5432/{Project_Name}
# Koneksi mengaktifkan TLS secara default (MD5 untuk autentikasi). Untuk menonaktifkan TLS secara eksplisit (misalnya, jika client tidak mendukungnya), atur parameter sslmode ke disable.
postgresql://{AccessKey_ID}:{AccessKey_Secret}@{Endpoint}:5432/{Project_Name}?sslmode=disable

Untuk terhubung ke SLS menggunakan protokol PostgreSQL melalui JDBC, gunakan konfigurasi berikut:

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("Koneksi berhasil!");
    }
}

Deskripsi parameter:

Buat tabel

Gunakan pernyataan CREATE TABLE untuk membuat logstore:

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
);

Tipe kolom yang didukung:

Properti tabel (klause WITH):

Ubah kolom

Operasi modifikasi kolom berikut didukung:

Tambah kolom:

ALTER TABLE users ADD COLUMN change_time TEXT;

Ubah nama kolom:

ALTER TABLE users RENAME COLUMN change_time TO update_time;

Ubah tipe kolom:

ALTER TABLE users ALTER COLUMN update_time TYPE TIMESTAMP;

Hapus kolom:

ALTER TABLE users DROP COLUMN update_time;

Bersihkan data

Gunakan pernyataan TRUNCATE untuk menghapus semua data dari tabel:

TRUNCATE TABLE users;

Catatan: Setelah data dihapus, perubahan tersebut memerlukan waktu sekitar 30 detik hingga terlihat dalam kueri SQL.

Hapus tabel

Gunakan pernyataan DROP TABLE untuk menghapus tabel (yang juga menghapus logstore terkait):

DROP TABLE users;

Kueri dasar

Gunakan pernyataan SELECT SQL standar untuk menanyakan data:

SELECT id, name FROM users LIMIT 10;

Catatan: Jika rentang waktu tidak ditentukan dalam pernyataan SQL, rentang waktu default yang ditentukan oleh default_query_range akan digunakan. Jika default_query_range tidak diatur saat tabel dibuat, kueri akan menggunakan data 15 menit terakhir secara default.

Tentukan rentang waktu kueri

Tentukan rentang waktu kueri dengan salah satu dari dua cara berikut:

-- Tentukan batas bawah rentang waktu
SELECT id, name FROM users 
WHERE __time__ > 1766646000
LIMIT 10;

-- Tentukan rentang waktu
SELECT id, name FROM users 
WHERE __time__ > 1766646000 AND __time__ < 1766646987
LIMIT 10;

-- Atur batas bawah rentang waktu
SET query_begin = 1766646000; 
SELECT id, name FROM users LIMIT 10;

-- Atur rentang waktu
SET query_begin = 1766646000; 
SET query_end = 1766646987; 
SELECT id, name FROM users LIMIT 10;

-- Atur variabel dalam satu pernyataan (disarankan)
SET query_begin = 1766646000; SET query_end = 1766646987; SELECT id, name FROM users LIMIT 10;

Penulisan dasar

Gunakan pernyataan INSERT INTO untuk menulis data:

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');

Penulisan EXACTLY-ONCE

Protokol PostgreSQL SLS tidak mendukung kendala keunikan seperti primary key, tetapi mendukung penulisan EXACTLY-ONCE untuk memastikan data hanya ditulis sekali.

Gunakan variabel hash_key dan seq_id untuk menerapkan penulisan 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');

Deskripsi parameter:

Penanganan error data duplikat:

Saat data duplikat ditulis, server mengembalikan pesan error dalam format berikut:

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

Gunakan ekspresi reguler berikut untuk mengekstrak seq_id saat ini dari respons server:

current\s+sequence_id=(\d+)

Kueri semua logstore

SELECT 
    table_schema, 
    table_name
FROM 
    information_schema.tables;

Catatan: Secara default, logstore dipetakan ke skema di bawah project dengan nama yang sama.

Kueri struktur bidang

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