|
|
@@ -145,6 +145,7 @@ class MyserviceDynamodb(object):
|
|
|
'latitude': latitude,
|
|
|
'appId': app_id,
|
|
|
'status_all': status_all,
|
|
|
+ 'ExpirationTime_TTL' : add_time+2592000,
|
|
|
'ip': ip,
|
|
|
}
|
|
|
)
|
|
|
@@ -173,12 +174,22 @@ class MyserviceDynamodb(object):
|
|
|
'longitude': longitude,
|
|
|
'latitude': latitude,
|
|
|
'appId': app_id,
|
|
|
+ 'ExpirationTime_TTL': add_time + 2592000,
|
|
|
'status_all': status_all,
|
|
|
'ip': ip,
|
|
|
}
|
|
|
)
|
|
|
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记录分页开始值
|
|
|
def get_page_line(self, page, line, table_name, last_evaluated,page_value):
|
|
|
dynamodb = self.session.resource('dynamodb')
|
|
|
@@ -225,8 +236,7 @@ class MyserviceDynamodb(object):
|
|
|
def item_get_count(self,table_name):
|
|
|
dynamodb = self.session.resource('dynamodb')
|
|
|
table = dynamodb.Table(table_name)
|
|
|
- response = table.scan(
|
|
|
- )
|
|
|
+ response = table.scan()
|
|
|
return len(response['Items'])
|
|
|
|
|
|
def item_get_brand(self,table_name):
|
|
|
@@ -443,6 +453,7 @@ class UserBrandInfo(View):
|
|
|
if param_flag is True:
|
|
|
try:
|
|
|
addTime = int(time.time())
|
|
|
+ print (time.time())
|
|
|
username = Device_User.objects.filter(userID = userID).values('userID','username','NickName')
|
|
|
username = username[0]['username']
|
|
|
# 添加user_brand_all表信息
|
chenjunkai