Correções gerais do projeto Lambda SQS

Author: andersoncontreira

examples/lambda_sqs/flambda_app/events_helper.py

@@ -58,6 +58,7 @@ def get_records_from_sqs_event(sqs_event, logger=None):
             if not helper.empty(sqs_event.to_dict()):
                 try:
                     sqs_event_dict = sqs_event.to_dict()
+                    # todo tratar <class 'boto3.resources.factory.sqs.Message'>
                     if 'Records' in sqs_event_dict:
                         sqs_event_dict = sqs_event_dict['Records']
                     for record in sqs_event_dict:

examples/lambda_sqs/tests/component/test_app.py

@@ -1,4 +1,5 @@
 import os
+import time
 import unittest
 from time import sleep
 
@@ -21,7 +22,13 @@
 
 def get_queue_message():
     queue_url = os.getenv("APP_QUEUE")
+
+    message = get_cancelamento_event()
+    SQSHelper.create_message(message, queue_url)
+    time.sleep(1)
+
     event = SQSHelper.get_message(queue_url)
+
     return (event,)
 
 
@@ -66,6 +73,9 @@ def setUpClass(cls):
 
     @data_provider(get_queue_message)
     def test_index(self, event):
+        """
+        TODO precisa de ajustes para funcionar
+        """
         self.logger.info('Running test: %s', get_function_name(__name__))
         self.logger.info('Event: {}'.format(event))