def test_run_event_source(self, mock_aws_client):
mock_aws_client.return_value.get_s3_file_list.return_value = ['test_file_1','test_file_2','test_file_3','test_file_4']
args = Args()
args.verbose = False
args.event_source = 'test_bucket'
Scar().run(args)
self.assertEqual(mock_aws_client.call_count, 1)
# check_function_name_not_exists
mock_aws_client.mock_calls[1].assert_called_with('test-name', False)
# get_s3_file_list
mock_aws_client.mock_calls[2].assert_called_with('test_bucket')
# launch_request_response_event
mock_aws_client.mock_calls[3].assert_called_with('test_file_1', {'Records': [{'eventSource': 'aws:s3', 's3': {'bucket': {'name': 'test_bucket'}, 'object': {'key': ''}}}]}, ANY, ANY)
# launch_async_event
mock_aws_client.mock_calls[4].assert_called_with('test_file_2', {'Records': [{'eventSource': 'aws:s3', 's3': {'bucket': {'name': 'test_bucket'}, 'object': {'key': ''}}}]}, ANY, ANY)
# launch_async_event
mock_aws_client.mock_calls[5].assert_called_with('test_file_3', {'Records': [{'eventSource': 'aws:s3', 's3': {'bucket': {'name': 'test_bucket'}, 'object': {'key': ''}}}]}, ANY, ANY)
# launch_async_event
mock_aws_client.mock_calls[6].assert_called_with('test_file_4', {'Records': [{'eventSource': 'aws:s3', 's3': {'bucket': {'name': 'test_bucket'}, 'object': {'key': ''}}}]}, ANY, ANY)
评论列表
文章目录