You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/12/19 08:48:15 UTC
[iotdb] branch python_delete_0.13 created (now 25248ea8b6)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch python_delete_0.13
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 25248ea8b6 [To rel/0.13][IOTDB-5236] Fix DeleteData Python API cannot work
This branch includes the following new commits:
new 25248ea8b6 [To rel/0.13][IOTDB-5236] Fix DeleteData Python API cannot work
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: [To rel/0.13][IOTDB-5236] Fix DeleteData Python API cannot work
Posted by ha...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch python_delete_0.13
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 25248ea8b6eff840c9b0df8647f2fc48513a1a56
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon Dec 19 16:47:26 2022 +0800
[To rel/0.13][IOTDB-5236] Fix DeleteData Python API cannot work
---
client-py/iotdb/Session.py | 18 +++++++++++++++++-
1 file changed, 17 insertions(+), 1 deletion(-)
diff --git a/client-py/iotdb/Session.py b/client-py/iotdb/Session.py
index 88af9e8343..9c0cecf7e4 100644
--- a/client-py/iotdb/Session.py
+++ b/client-py/iotdb/Session.py
@@ -345,7 +345,23 @@ class Session(object):
:param paths_list: time series list that the data in.
:param timestamp: data with time stamp less than or equal to time will be deleted.
"""
- request = TSDeleteDataReq(self.__session_id, paths_list, timestamp)
+ request = TSDeleteDataReq(self.__session_id, paths_list, -9223372036854775808, end_time)
+ try:
+ status = self.__client.deleteData(request)
+ logger.debug(
+ "delete data from {}, message: {}".format(paths_list, status.message)
+ )
+ except TTransport.TException as e:
+ logger.exception("data deletion fails because: ", e)
+
+ def delete_data_in_range(self, paths_list, start_time, end_time):
+ """
+ delete data >= start_time and data <= end_time in multiple timeseries
+ :param paths_list: time series list that the data in.
+ :param start_time: delete range start time.
+ :param end_time: delete range end time.
+ """
+ request = TSDeleteDataReq(self.__session_id, paths_list, start_time, end_time)
try:
status = self.__client.deleteData(request)
logger.debug(