Add log update and delete v2 APIs

aliyun/log/__init__.py

@@ -39,6 +39,10 @@
 from .rebuild_index_response import *
 from .deletelogsrequest import *
 from .deletelogssresponse import *
+from .deletelogsv2request import *
+from .deletelogsv2response import *
+from .updatelogsrequest import *
+from .updatelogsresponse import *
 from .getdeletelogsstatusrequest import *
 from .getdeletelogsstatusresponse import *
 from .listdeletelogsstasksrequest import *

aliyun/log/__init__.pyi

@@ -39,6 +39,10 @@ from .proto import LogGroupRaw as LogGroup
 from .rebuild_index_response import CreateRebuildIndexResponse as CreateRebuildIndexResponse, GetRebuildIndexResponse as GetRebuildIndexResponse
 from .deletelogsrequest import DeleteLogsRequest as DeleteLogsRequest
 from .deletelogssresponse import DeleteLogsResponse as DeleteLogsResponse
+from .deletelogsv2request import DeleteLogsV2Request as DeleteLogsV2Request
+from .deletelogsv2response import DeleteLogsV2Response as DeleteLogsV2Response
+from .updatelogsrequest import UpdateLogsRequest as UpdateLogsRequest
+from .updatelogsresponse import UpdateLogsResponse as UpdateLogsResponse
 from .getdeletelogsstatusrequest import GetDeleteLogsStatusRequest as GetDeleteLogsStatusRequest
 from .getdeletelogsstatusresponse import GetDeleteLogsStatusResponse as GetDeleteLogsStatusResponse
 from .listdeletelogsstasksrequest import ListDeleteLogsTasksRequest as ListDeleteLogsTasksRequest

aliyun/log/deletelogsv2request.py

@@ -0,0 +1,114 @@
+#!/usr/bin/env python
+# encoding: utf-8
+
+# Copyright (C) Alibaba Cloud Computing
+# All rights reserved.
+
+from .logrequest import LogRequest
+from .util import parse_timestamp
+
+
+class DeleteLogsV2Request(LogRequest):
+    """The request used to delete logs from a logstore.
+
+    :type project: string
+    :param project: project name
+
+    :type logstore: string
+    :param logstore: logstore name
+
+    :type fromTime: int/string
+    :param fromTime: the begin time
+
+    :type toTime: int/string
+    :param toTime: the end time
+
+    :type query: string
+    :param query: user defined query
+
+    :type rowId: string
+    :param rowId: row id of the log
+    """
+
+    def __init__(self, project=None, logstore=None, fromTime=None, toTime=None, query=None, rowId=None):
+        LogRequest.__init__(self, project)
+        self.logstore = logstore
+        self.fromTime = parse_timestamp(fromTime) if fromTime is not None else fromTime
+        self.toTime = parse_timestamp(toTime) if toTime is not None else toTime
+        self.query = query
+        self.rowId = rowId
+
+    def get_logstore(self):
+        """Get logstore name.
+
+        :return: string, logstore name.
+        """
+        return self.logstore if self.logstore else ''
+
+    def set_logstore(self, logstore):
+        """Set logstore name.
+
+        :type logstore: string
+        :param logstore: logstore name
+        """
+        self.logstore = logstore
+
+    def get_from(self):
+        """Get begin time.
+
+        :return: int, begin time
+        """
+        return self.fromTime
+
+    def set_from(self, fromTime):
+        """Set begin time.
+
+        :type fromTime: int/string
+        :param fromTime: begin time
+        """
+        self.fromTime = parse_timestamp(fromTime) if fromTime is not None else fromTime
+
+    def get_to(self):
+        """Get end time.
+
+        :return: int, end time
+        """
+        return self.toTime
+
+    def set_to(self, toTime):
+        """Set end time.
+
+        :type toTime: int/string
+        :param toTime: end time
+        """
+        self.toTime = parse_timestamp(toTime) if toTime is not None else toTime
+
+    def get_query(self):
+        """Get user defined query.
+
+        :return: string, user defined query
+        """
+        return self.query
+
+    def set_query(self, query):
+        """Set user defined query.
+
+        :type query: string
+        :param query: user defined query
+        """
+        self.query = query
+
+    def get_row_id(self):
+        """Get row id.
+
+        :return: string, row id
+        """
+        return self.rowId
+
+    def set_row_id(self, rowId):
+        """Set row id.
+
+        :type rowId: string
+        :param rowId: row id
+        """
+        self.rowId = rowId

aliyun/log/deletelogsv2request.pyi

@@ -0,0 +1,17 @@
+# -*- coding: utf-8 -*-
+from typing import Optional, Union
+
+from .logrequest import LogRequest
+
+class DeleteLogsV2Request(LogRequest):
+    def __init__(self, project: Optional[str] = ..., logstore: Optional[str] = ..., fromTime: Optional[Union[int, str]] = ..., toTime: Optional[Union[int, str]] = ..., query: Optional[str] = ..., rowId: Optional[str] = ...) -> None: ...
+    def get_logstore(self) -> str: ...
+    def set_logstore(self, logstore: str) -> None: ...
+    def get_from(self) -> Optional[int]: ...
+    def set_from(self, fromTime: Optional[Union[int, str]]) -> None: ...
+    def get_to(self) -> Optional[int]: ...
+    def set_to(self, toTime: Optional[Union[int, str]]) -> None: ...
+    def get_query(self) -> Optional[str]: ...
+    def set_query(self, query: Optional[str]) -> None: ...
+    def get_row_id(self) -> Optional[str]: ...
+    def set_row_id(self, rowId: Optional[str]) -> None: ...

aliyun/log/deletelogsv2response.py

@@ -0,0 +1,23 @@
+#!/usr/bin/env python
+# encoding: utf-8
+
+# Copyright (C) Alibaba Cloud Computing
+# All rights reserved.
+
+from .logresponse import LogResponse
+
+
+class DeleteLogsV2Response(LogResponse):
+    """The response of the DeleteLogsV2 API from log."""
+
+    def __init__(self, resp, header):
+        LogResponse.__init__(self, header, resp)
+        self.affected_rows = resp.get('affected_rows', 0)
+
+    def get_affected_rows(self):
+        return self.affected_rows
+
+    def log_print(self):
+        print('DeleteLogsV2Response:')
+        print('headers:', self.get_all_headers())
+        print('affected_rows:', self.affected_rows)

aliyun/log/deletelogsv2response.pyi

@@ -0,0 +1,10 @@
+# -*- coding: utf-8 -*-
+from typing import Any, Dict
+
+from .logresponse import LogResponse
+
+class DeleteLogsV2Response(LogResponse):
+    affected_rows: int
+    def __init__(self, resp: Dict[str, Any], header: Dict[str, Any]) -> None: ...
+    def get_affected_rows(self) -> int: ...
+    def log_print(self) -> None: ...