Simple Log Service：Memulai dengan Simple Log Service SDK untuk Python

Dalam contoh ini, file SLSQuickStart.py dibuat. Kode sampel dalam file ini memberikan contoh tentang cara memanggil operasi API untuk membuat proyek, mengonfigurasi penyimpanan log, membuat indeks, menulis log, serta menanyakan log. Contoh kode:

from aliyun.log import LogClient, PutLogsRequest, LogItem, GetLogsRequest, IndexConfig
import time
import os

# Konfigurasikan variabel lingkungan. Dalam contoh ini, ID AccessKey dan rahasia AccessKey diperoleh dari variabel lingkungan.
accessKeyId = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_ID', '')
accessKey = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_SECRET', '')
# Titik akhir Simple Log Service. Dalam contoh ini, titik akhir Simple Log Service untuk wilayah China (Hangzhou) digunakan. Ganti nilai parameter dengan titik akhir sebenarnya.
endpoint = "cn-hangzhou.log.aliyuncs.com"

# Buat klien Simple Log Service.
client = LogClient(endpoint, accessKeyId, accessKey)

# Nama proyek.
project_name = "aliyun-test-project"
# Nama penyimpanan log.
logstore_name = "aliyun-test-logstore"
# Pernyataan query.
query = "*| select dev,id from " + logstore_name
# Indeks.
logstore_index = {'line': {
    'token': [',', ' ', "'", '"', ';', '=', '(', ')', '[', ']', '{', '}', '?', '@', '&', '<', '>', '/', ':', '\n', '\t',
              '\r'], 'caseSensitive': False, 'chn': False}, 'keys': {'dev': {'type': 'text',
                                                                             'token': [',', ' ', "'", '"', ';', '=',
                                                                                       '(', ')', '[', ']', '{', '}',
                                                                                       '?', '@', '&', '<', '>', '/',
                                                                                       ':', '\n', '\t', '\r'],
                                                                             'caseSensitive': False, 'alias': '',
                                                                             'doc_value': True, 'chn': False},
                                                                     'id': {'type': 'long', 'alias': '',
                                                                            'doc_value': True}}, 'log_reduce': False,
    'max_text_len': 2048}

# Parameter from_time dan to_time menentukan waktu mulai dan waktu akhir rentang waktu di mana Anda ingin menanyakan log. Nilai-nilai parameter tersebut adalah timestamp UNIX.
from_time = int(time.time()) - 3600
to_time = time.time() + 3600

# Buat proyek.
def create_project():
    print("siap untuk membuat proyek %s" % project_name)
    client.create_project(project_name, project_des="")
    print("buat proyek %s berhasil " % project_name)
    time.sleep(60)

# Buat penyimpanan log.
def create_logstore():
    print("siap untuk membuat penyimpanan log %s" % logstore_name)
    client.create_logstore(project_name, logstore_name, ttl=3, shard_count=2)
    print("buat penyimpanan log %s berhasil " % project_name)
    time.sleep(30)

# Buat indeks.
def create_index():
    print("siap untuk membuat indeks untuk %s" % logstore_name)
    index_config = IndexConfig()
    index_config.from_json(logstore_index)
    client.create_index(project_name, logstore_name, index_config)
    print("buat indeks untuk %s berhasil " % logstore_name)
    time.sleep(60 * 2)

# Tulis data ke penyimpanan log.
def put_logs():
    print("siap untuk menulis log untuk %s" % logstore_name)
    log_group = []
    for i in range(0, 100):
        log_item = LogItem()
        contents = [
            ('dev', 'test_put'),
            ('id', str(i))
        ]
        log_item.set_contents(contents)
        log_group.append(log_item)
    request = PutLogsRequest(project_name, logstore_name, "", "", log_group, compress=False)
    client.put_logs(request)
    print("tulis log untuk %s berhasil " % logstore_name)
    time.sleep(60)


# Eksekusi pernyataan SQL untuk menanyakan log.
def get_logs():
    print("siap untuk menanyakan log dari penyimpanan log %s" % logstore_name)
    request = GetLogsRequest(project_name, logstore_name, from_time, to_time, query=query)
    response = client.get_logs(request)
    for log in response.get_logs():
        for k, v in log.contents.items():
            print("%s : %s" % (k, v))
        print("*********************")


if __name__ == '__main__':
    # Buat proyek.
    create_project()
    # Buat penyimpanan log.
    create_logstore()
    # Buat indeks.
    create_index()
    # Tulis data ke penyimpanan log.
    put_logs()
    # Eksekusi pernyataan SQL untuk menanyakan log.
    get_logs()