|
@@ -46,9 +46,19 @@ class AmazonKinesisVideoObject:
|
|
|
@return : True or False
|
|
|
"""
|
|
|
try:
|
|
|
- self.client_conn.update_data_retention(StreamName=stream_name, Operation=operation,
|
|
|
+ version = self.describe_stream(stream_name)['Version']
|
|
|
+ self.client_conn.update_data_retention(StreamName=stream_name, Operation=operation, CurrentVersion=version,
|
|
|
DataRetentionChangeInHours=data_retention_change_in_hours)
|
|
|
return True
|
|
|
except Exception as e:
|
|
|
print(e)
|
|
|
return False
|
|
|
+
|
|
|
+ def describe_stream(self, stream_name):
|
|
|
+ """
|
|
|
+ 获取视频流信息数据
|
|
|
+ @param stream_name: 视频流名称
|
|
|
+ @return stream_info: 视频流信息数据
|
|
|
+ """
|
|
|
+ return self.client_conn.describe_stream(StreamName=stream_name)['StreamInfo']
|
|
|
+
|