tratativas localhost/docker

Author: andersoncontreira

examples/lambda_api/lambda_app/database/mysql.py

@@ -56,7 +56,10 @@ def get_connection(config=None, connect=True, retry=False):
                     _RETRY_COUNT += 1
                     # Fix para tratar diff entre docker/local
                     if config.DB_HOST == 'mysql':
+                        old_value = config.DB_HOST
                         config.DB_HOST = 'localhost'
+                        logger.info(
+                            'Changing the endpoint from {} to {}'.format(old_value, config.DB_HOST))
                     return get_connection(config, True)
     else:
         connection = _CONNECTION

examples/lambda_sqs/lambda_app/database/mysql.py

@@ -56,7 +56,10 @@ def get_connection(config=None, connect=True, retry=False):
                     _RETRY_COUNT += 1
                     # Fix para tratar diff entre docker/local
                     if config.DB_HOST == 'mysql':
+                        old_value = config.DB_HOST
                         config.DB_HOST = 'localhost'
+                        logger.info(
+                            'Changing the endpoint from {} to {}'.format(old_value, config.DB_HOST))
                     return get_connection(config, True)
     else:
         connection = _CONNECTION

examples/lambda_sqs/lambda_app/services/v1/carrier_notifier_service.py

@@ -80,6 +80,7 @@ def get_records_from_sqs_event(self, sqs_event):
         records = []
         try:
             if isinstance(sqs_event, SQSEvent):
+                self.logger.info("SQSEvent instance")
                 if not helper.empty(sqs_event.to_dict()):
                     try:
                         sqs_event_dict = sqs_event.to_dict()
@@ -91,6 +92,7 @@ def get_records_from_sqs_event(self, sqs_event):
                         self.logger.error(err)
                         records.append(sqs_event.to_dict())
             elif isinstance(sqs_event, SQSRecord):
+                self.logger.info("SQSRecord instance")
                 if not helper.empty(sqs_event.to_dict()):
                     records.append(sqs_event)
         except Exception as err:

examples/lambda_sqs/samples/localstack/sqs/sample.json

@@ -1,6 +1,23 @@
 {
-   "chavenfe": "32210206107255000134550010001712551245826554",
-   "ocor": "MOTIVO DO CANCELAMENTO",
-   "origem": "SAC/EAGLE",
-   "pedido": "Z1223321"
+    "Records": [
+        {
+            "messageId": "11d6ee51-4cc7-4302-9e22-7cd8afdaadf5",
+            "receiptHandle": "AQEBBX8nesZEXmkhsmZeyIE8iQAMig7qw...",
+            "body": "{\n   \"chavenfe\": \"32210206107255000134550010001712551245826554\",\n   \"ocor\": \"MOTIVO DO CANCELAMENTO\",\n   \"origem\": \"SAC/EAGLE\",\n   \"pedido\": \"Z1223321\"\n}",
+            "attributes": {
+                "ApproximateReceiveCount": "1",
+                "SentTimestamp": "1573251510774",
+                "SequenceNumber": "18849496460467696128",
+                "MessageGroupId": "1",
+                "SenderId": "AIDAIO23YVJENQZJOL4VO",
+                "MessageDeduplicationId": "1",
+                "ApproximateFirstReceiveTimestamp": "1573251510774"
+            },
+            "messageAttributes": {},
+            "md5OfBody": "e4e68fb7bd0e697a0ae8f1bb342846b3",
+            "eventSource": "aws:sqs",
+            "eventSourceARN": "arn:aws:sqs:us-east-2:683720833731:fretzy-delivery-time-simulator-queue.fifo",
+            "awsRegion": "us-east-2"
+        }
+    ]
 }

examples/lambda_sqs/tests/component/test_app.py

@@ -1,5 +1,6 @@
 import os
 import unittest
+from time import sleep
 
 from tests.component.componenttestutils import BaseComponentTestCase
 from lambda_app import helper
@@ -31,6 +32,7 @@ def get_queue_events_samples():
 
 # AttributeError: module 'typing' has no attribute '_classvar'
 # This error occours on Python 3.8
+# If you will consume items from the queue, dont boot the lambda
 class AppTestCase(BaseComponentTestCase):
     """
 
@@ -74,6 +76,7 @@ def fixture_sqs(cls, logger, queue_url):
         SQSHelper.create_message(message, queue_url)
         logger.info('created message: {}'.format(message))
         # message = SQSHelper.get_message(queue_url)
+        # logger.info('reading message: {}'.format(message))
         # print(message)
 
     @data_provider(get_queue_message)

examples/lambda_sqs/tests/component/test_lambda_app/services/v1/test_carrier_notifier_service.py

@@ -20,14 +20,14 @@ def get_queue_message():
     queue_url = os.getenv("APP_QUEUE")
     event = SQSHelper.get_message(queue_url)
 
-    return (event,)
+    return (event,),
 
 
 def get_queue_events_samples():
     event = get_cancelamento_event()
     sqs_event = create_chalice_sqs_event(event)
 
-    return (sqs_event,)
+    return (sqs_event,),
 
 
 class CarrierNotifierServiceTestCase(BaseComponentTestCase):