ScheduledTasks/applications/aliyunLog.py

"""
@author: luojunhui
"""
from aliyun.log import LogClient, GetLogsRequest


class AliyunLog(object):
    """
    Aliyun Log Class
    """
    access_key_id = 'LTAIP6x1l3DXfSxm'
    access_key_secret = 'KbTaM9ars4OX3PMS6Xm7rtxGr1FLon'
    project = 'wqsd-video'
    log_store = 'video-action-log'
    endpoint = "cn-hangzhou.log.aliyuncs.com"

    # 初始化日志客户端
    client = LogClient(endpoint, access_key_id, access_key_secret)

    @classmethod
    def get_log(cls, start_time, end_time, query, topic=''):
        """
        :param topic:
        :param start_time:
        :param end_time:
        :param query:
        :return:
        """
        request = GetLogsRequest(
            cls.project,
            cls.log_store,
            start_time,
            end_time,
            topic,
            query
        )
        response = cls.client.get_logs(request)
        if response.get_count() > 0:
            for log in response.get_logs():
                print(log.log_print())
                # for content in log.get_contents():
                #     print(content)
        else:
            print("没有日志数据")