通过Cursor查询服务器端时间_日志服务(SLS)-阿里云帮助中心

前提条件

您已完成以下操作：

参数说明

def get_cursor(self, project_name, logstore_name, shard_id, start_time):

请求参数

名称	类型	是否必填	说明
project_name	String	是	Project名称：项目（Project）是日志服务的资源管理单元，是进行多用户隔离与访问控制的主要边界。更多信息，请参见管理Project。
logstore_name	String	是	Logstore名称：Logstore是日志服务中日志数据的采集、存储和查询单元。更多信息，请参见管理Logstore。
shard_id	int	是	日志库的分区ID，更多信息，请参见分区（Shard）。
cursor	String	是	希望获取时间戳的Cursor。从接口GetCursor可以获取Cursor值。说明如果Cursor取值小于`Begin Cursor`或者Cursor取值大于`End Cursor`，返回 InvalidCursor。当 Shard 中无数据时，返回当前时间。

返回参数

返回参数请参见：GetCursorTime - 通过Cursor查询服务器端时间。

示例代码

from aliyun.log import LogClient
import os

# 本示例从环境变量中获取AccessKey ID和AccessKey Secret
access_key_id = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_ID', '')
access_key_secret = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_SECRET', '')
# 日志服务的服务接入点
endpoint = "cn-hangzhou.log.aliyuncs.com"

# 实例化LogClient类
client = LogClient(endpoint, access_key_id, access_key_secret)

project_name = "proj-test-1"
logstore_name = "logstore-1"
shard_id = 1
cursor = "MTcyMTYzO****MTI5MjE0Ng=="


def main():
    # 根据时间获取对应的游标（Cursor）
    response = client.get_cursor_time(project_name, logstore_name, shard_id, cursor)
    response.log_print()


if __name__ == '__main__':
    main()

示例返回结果

GetCursorTimeResponse
headers: {'Server': 'AliyunSLS', 'Content-Type': 'application/json', 'Content-Length': '26', 'Connection': 'keep-alive', 'Access-Control-Allow-Origin': '*', 'Date': 'Tue, 15 Oct 2024 07:03:31 GMT', 'x-log-time': '1728975811', 'x-log-requestid': '670E13C354D4D7B93256****'}
cursor_time: 1728959278

Process finished with exit code 0

前提条件

参数说明

请求参数

返回参数

示例代码

示例返回结果

相关文档