日志庫(Logstore)是日志服務中數據的采集、存儲和查詢單元。每個Logstore隸屬于一個Project,每個Project中可創建多個Logstore。本文通過代碼示例介紹如何創建、修改、查詢、刪除Logstore等。
前提條件
已開通日志服務。更多信息,請參見開通日志服務。
已創建RAM用戶并完成授權。具體操作,請參見創建RAM用戶并完成授權。
已配置環境變量ALIBABA_CLOUD_ACCESS_KEY_ID和ALIBABA_CLOUD_ACCESS_KEY_SECRET。具體操作,請參見在Linux、macOS和Windows系統配置環境變量。
重要阿里云賬號的AccessKey擁有所有API的訪問權限,建議您使用RAM用戶的AccessKey進行API訪問或日常運維。
強烈建議不要把AccessKey ID和AccessKey Secret保存到工程代碼里,否則可能導致AccessKey泄露,威脅您賬號下所有資源的安全。
已安裝日志服務Python SDK。具體操作,請參見安裝Python SDK。
已創建Project。具體操作,請參見創建項目Project。
注意事項
本示例以華東1(杭州)的公網Endpoint為例,其公網Endpoint為https://cn-hangzhou.log.aliyuncs.com
。如果您通過與Project同地域的其他阿里云產品訪問日志服務,請使用內網Endpointhttps://cn-hangzhou-intranet.log.aliyuncs.com
。關于日志服務支持的地域與Endpoint的對應關系,請參見服務入口。
創建Logstore示例代碼
以下代碼用于創建名為ali-test-logstore的Logstore。
from aliyun.log import LogClient
import os
# 本示例從環境變量中獲取AccessKey ID和AccessKey Secret。
accessKeyId = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_ID', '')
accessKey = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_SECRET', '')
# 日志服務的服務接入點。此處以杭州為例,其它地域請根據實際情況填寫。
endpoint = "cn-hangzhou.log.aliyuncs.com"
# 創建日志服務Client。
client = LogClient(endpoint, accessKeyId, accessKey)
# Project名稱。
project_name = "ali-test-project"
# Logstore名稱。
logstore_name = "ali-test-logstore"
# 創建Logstore。
def create_logstore():
print("ready to create logstore %s" %logstore_name)
# 創建標準型Logstore,數據保存時間為30天,其他參數使用默認值。
client.create_logstore(project_name, logstore_name, ttl = 30, hot_ttl=-1)
print("create logstore %s success " %logstore_name)
# 查詢Logstore。
def get_logstore():
print("ready to get logstore")
res = client.get_logstore(project_name, logstore_name)
res.log_print()
print("get logstore success ")
if __name__ == '__main__':
# 創建Logstore。
create_logstore()
# 查詢Logstore。
get_logstore()
預期結果如下:
ready to create logstore ali-test-logstore
create logstore ali-test-logstore success
ready to get logstore
GetLogStoreResponse:
headers: {'Server': 'Tengine', 'Content-Type': 'application/json', 'Content-Length': '319', 'Connection': 'keep-alive', 'Access-Control-Allow-Origin': '*', 'Date': 'Fri, 16 Dec 2022 07:04:37 GMT', 'x-log-time': '1671174277', 'x-log-requestid': '639C18851A0CDA516EFA437B'}
logstore_name: ali-test-logstore3
shard_count: 2
ttl: 30
get logstore success
修改Logstore示例代碼
以下代碼用于修改指定Logstore的配置。
from aliyun.log import LogClient
import os
# 本示例從環境變量中獲取AccessKey ID和AccessKey Secret。
accessKeyId = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_ID', '')
accessKey = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_SECRET', '')
# 日志服務的服務接入點。此處以杭州為例,其它地域請根據實際情況填寫。
endpoint = "cn-hangzhou.log.aliyuncs.com"
# 創建日志服務Client。
client = LogClient(endpoint, accessKeyId, accessKey)
# Project名稱。
project_name = "ali-test-project"
# Logstore名稱。
logstore_name = "ali-test-logstore"
# 修改Logstore。
def update_logstore():
print("ready to update logstore %s" %logstore_name)
# 更新數據保存時間為60天。
client.update_logstore(project_name,logstore_name,ttl=60)
print("update logstore %s success " %logstore_name)
# 查詢Logstore。
def get_logstore():
print("ready to get logstore")
res = client.get_logstore(project_name, logstore_name)
res.log_print()
print("get logstore success ")
if __name__ == '__main__':
# 修改Logstore。
update_logstore()
# 查詢Logstore。
get_logstore()
預期結果如下:
ready to update logstore ali-test-logstore
update logstore ali-test-logstore success
ready to get logstore
GetLogStoreResponse:
headers: {'Server': 'Tengine', 'Content-Type': 'application/json', 'Content-Length': '319', 'Connection': 'keep-alive', 'Access-Control-Allow-Origin': '*', 'Date': 'Fri, 16 Dec 2022 07:10:02 GMT', 'x-log-time': '1671174602', 'x-log-requestid': '639C19CAED4C6B234D66E5C1'}
logstore_name: ali-test-logstore3
shard_count: 2
ttl: 60
get logstore success
查詢所有Logstore示例代碼
以下代碼用于查詢所有Logstore。
from aliyun.log import LogClient
import os
# 本示例從環境變量中獲取AccessKey ID和AccessKey Secret。
accessKeyId = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_ID', '')
accessKey = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_SECRET', '')
# 日志服務的服務接入點。此處以杭州為例,其它地域請根據實際情況填寫。
endpoint = "cn-hangzhou.log.aliyuncs.com"
# 創建日志服務Client。
client = LogClient(endpoint, accessKeyId, accessKey)
# Project名稱。
project_name = "ali-test-project"
if __name__ == '__main__':
# 查詢所有Logstore列表。
print("ready to list logstore")
res = client.list_logstore(project_name, None, 0, 100)
for logstore in res.get_logstores():
print(logstore)
print("list logstore success")
預期結果如下:
ready to list logstore
ali-test-logstore
ali-test-logstore2
ali-test-webtracking
list logstore success
刪除Logstore示例代碼
以下代碼用于刪除名為ali-test-logstore的Logstore。
from aliyun.log import LogClient
import os
# 本示例從環境變量中獲取AccessKey ID和AccessKey Secret。
accessKeyId = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_ID', '')
accessKey = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_SECRET', '')
# 日志服務的服務接入點。此處以杭州為例,其它地域請根據實際情況填寫。
endpoint = "cn-hangzhou.log.aliyuncs.com"
# 創建日志服務Client。
client = LogClient(endpoint, accessKeyId, accessKey)
# Project名稱。
project_name = "ali-test-project"
# Logstore名稱。
logstore_name = "ali-test-logstore"
if __name__ == '__main__':
# 刪除Logstore。
print("ready to delete logstore")
client.delete_logstore(project_name, logstore_name)
print("delete logstore %s success " %logstore_name)
預期結果如下:
ready to delete logstore
delete logstore ali-test-logstore success
相關文檔
在調用API接口過程中,若服務端返回結果中包含錯誤信息,則表示調用API接口失敗。您可以參考API錯誤碼對照表查找對應的解決方法。更多信息,請參見API錯誤處理對照表。
阿里云OpenAPI開發者門戶提供調試、SDK、示例和配套文檔。通過OpenAPI,您無需手動封裝請求和簽名操作,就可以快速對日志服務API進行調試。更多信息,請參見OpenAPI開發者門戶。
為滿足越來越多的自動化日志服務配置需求,日志服務提供命令行工具CLI(Command Line Interface)。更多信息,請參見日志服務命令行工具CLI。
更多示例代碼,請參見Aliyun Log Python SDK on GitHub。