Yasuke/moto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

type of json field - nextSequenceToken that return by cloudwatch logs putLogEvents should be string, not int.

Browse Source
This commit is contained in:
chrisLeeTW 2018-08-11 22:14:04 +08:00
parent 42d486f9b0
commit 001a7d0278
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
moto/logs/models.py
View File

@ -86,7 +86,7 @@ class LogStream:
self.events += [LogEvent(self.lastIngestionTime, log_event) for log_event in log_events] self.events += [LogEvent(self.lastIngestionTime, log_event) for log_event in log_events]
self.uploadSequenceToken += 1 self.uploadSequenceToken += 1
return self.uploadSequenceToken return '{:056d}'.format(self.uploadSequenceToken)
def get_log_events(self, log_group_name, log_stream_name, start_time, end_time, limit, next_token, start_from_head): def get_log_events(self, log_group_name, log_stream_name, start_time, end_time, limit, next_token, start_from_head):
def filter_func(event): def filter_func(event):

8
tests/test_logs/test_logs.py
View File

@ -1,5 +1,6 @@
import boto3 import boto3
import sure # noqa import sure # noqa
import six
from botocore.exceptions import ClientError from botocore.exceptions import ClientError
from moto import mock_logs, settings from moto import mock_logs, settings
@ -47,7 +48,7 @@ def test_exceptions():
logEvents=[ logEvents=[
{ {
'timestamp': 0, 'timestamp': 0,
'message': 'line' 'message': 'line'
}, },
], ],
) )
@ -79,7 +80,7 @@ def test_put_logs():
{'timestamp': 0, 'message': 'hello'}, {'timestamp': 0, 'message': 'hello'},
{'timestamp': 0, 'message': 'world'} {'timestamp': 0, 'message': 'world'}
] ]
conn.put_log_events( putRes = conn.put_log_events(
logGroupName=log_group_name, logGroupName=log_group_name,
logStreamName=log_stream_name, logStreamName=log_stream_name,
logEvents=messages logEvents=messages
@ -89,6 +90,9 @@ def test_put_logs():
logStreamName=log_stream_name logStreamName=log_stream_name
) )
events = res['events'] events = res['events']
nextSequenceToken = putRes['nextSequenceToken']
assert isinstance(nextSequenceToken, six.string_types) == True
assert len(nextSequenceToken) == 56
events.should.have.length_of(2) events.should.have.length_of(2)