|
@@ -91,13 +91,15 @@ class MyserviceDynamodb():
|
|
|
try:
|
|
|
table = dynamodb.Table(table_name)
|
|
|
response = table.scan(
|
|
|
+ Select='COUNT',
|
|
|
FilterExpression=(Attr('addTime').gt(start_date)
|
|
|
& Key('addTime').lt(end_date)) | Key('addTime').eq(start_date)
|
|
|
)
|
|
|
+ items = response['Count']
|
|
|
+ return items
|
|
|
except Exception as e:
|
|
|
logger.error("Failed to get table {0}, error".format(table_name, e))
|
|
|
- items = response['Items']
|
|
|
- return len(items)
|
|
|
+ return 0
|
|
|
|
|
|
# 时间段搜索
|
|
|
def get_item_date(self, table_name, date):
|
|
@@ -115,10 +117,12 @@ class MyserviceDynamodb():
|
|
|
start_date = int(start_date.timestamp())
|
|
|
end_date = int(end_date.timestamp())
|
|
|
response = table.scan(
|
|
|
+ Select = 'COUNT',
|
|
|
FilterExpression=(Attr('addTime').gt(start_date)
|
|
|
& Key('addTime').lt(end_date)) | Key('addTime').eq(start_date)
|
|
|
)
|
|
|
- count = len(response['Items'])
|
|
|
+ print (response['Count'])
|
|
|
+ count = response['Count']
|
|
|
if count:
|
|
|
res[k] = count
|
|
|
else:
|
|
@@ -435,7 +439,7 @@ def dynamo_db_add_log_ctr(request, status_code):
|
|
|
num = 1
|
|
|
clientIP = CommonService.get_ip_address(request)
|
|
|
token = request_dict.get('token', None)
|
|
|
- userID = ''
|
|
|
+ userID = '无'
|
|
|
if token is not None:
|
|
|
tko = TokenObject(token)
|
|
|
userID = tko.userID
|