pzb 6 жил өмнө
parent
commit
90b8ca1de3

+ 13 - 2
Controller/UserBrandController.py

@@ -145,6 +145,7 @@ class MyserviceDynamodb(object):
                 'latitude': latitude,
                 'latitude': latitude,
                 'appId': app_id,
                 'appId': app_id,
                 'status_all': status_all,
                 'status_all': status_all,
+                'ExpirationTime_TTL' : add_time+2592000,
                 'ip': ip,
                 'ip': ip,
             }
             }
         )
         )
@@ -173,12 +174,22 @@ class MyserviceDynamodb(object):
                 'longitude': longitude,
                 'longitude': longitude,
                 'latitude': latitude,
                 'latitude': latitude,
                 'appId': app_id,
                 'appId': app_id,
+                'ExpirationTime_TTL': add_time + 2592000,
                 'status_all': status_all,
                 'status_all': status_all,
                 'ip': ip,
                 'ip': ip,
             }
             }
         )
         )
         print ('添加数据成功!')
         print ('添加数据成功!')
 
 
+    def get_time_to_live(self,table_name):
+        dynamodb = self.session.resource('dynamodb')
+        if not dynamodb:
+            raise DynamodbConnectionError("Failed to get resource for dynamodb!")
+        table = dynamodb.Table(table_name)
+        response = table.describe_time_to_live()
+        print (response)
+        print ('生命周期')
+
     # page分页数,line条数,table_name表名称,last_evaluated查询开始值,page_value记录分页开始值
     # page分页数,line条数,table_name表名称,last_evaluated查询开始值,page_value记录分页开始值
     def get_page_line(self, page, line, table_name, last_evaluated,page_value):
     def get_page_line(self, page, line, table_name, last_evaluated,page_value):
         dynamodb = self.session.resource('dynamodb')
         dynamodb = self.session.resource('dynamodb')
@@ -225,8 +236,7 @@ class MyserviceDynamodb(object):
     def item_get_count(self,table_name):
     def item_get_count(self,table_name):
         dynamodb = self.session.resource('dynamodb')
         dynamodb = self.session.resource('dynamodb')
         table = dynamodb.Table(table_name)
         table = dynamodb.Table(table_name)
-        response = table.scan(
-        )
+        response = table.scan()
         return len(response['Items'])
         return len(response['Items'])
 
 
     def item_get_brand(self,table_name):
     def item_get_brand(self,table_name):
@@ -443,6 +453,7 @@ class UserBrandInfo(View):
         if param_flag is True:
         if param_flag is True:
             try:
             try:
                 addTime = int(time.time())
                 addTime = int(time.time())
+                print (time.time())
                 username = Device_User.objects.filter(userID = userID).values('userID','username','NickName')
                 username = Device_User.objects.filter(userID = userID).values('userID','username','NickName')
                 username = username[0]['username']
                 username = username[0]['username']
                 # 添加user_brand_all表信息
                 # 添加user_brand_all表信息