Pequeno fix para suportar o evento que vai estar chegando da API

Author: andersoncontreira

examples/lambda_sqs/lambda_app/__init__.py

@@ -1,3 +1,3 @@
-APP_NAME = 'template-serverless-lambda-python-lambda-api'
+APP_NAME = 'template-serverless-lambda-python-lambda-sqs'
 APP_VERSION = '1.0.0'
 APP_ARCH_VERSION = 'v1'

examples/lambda_sqs/lambda_app/config.py

@@ -28,9 +28,6 @@ class Configuration:
     DB = ""
 
     APP_QUEUE = ""
-    APP_SALES_QUEUE = ""
-    APP_DECISION_QUEUE = ""
-    APP_RULES_QUEUE = ""
 
     REDIS_HOST = ""
     REDIS_PORT = 6379
@@ -55,10 +52,6 @@ def __init__(self):
         self.DB = os.getenv("DB") if 'DB' in os.environ else self.DB
 
         self.APP_QUEUE = os.getenv("APP_QUEUE") if 'APP_QUEUE' in os.environ else self.APP_QUEUE
-        self.APP_SALES_QUEUE = os.getenv("APP_SALES_QUEUE") if 'APP_SALES_QUEUE' in os.environ else self.APP_SALES_QUEUE
-        self.APP_DECISION_QUEUE = os.getenv(
-            "APP_DECISION_QUEUE") if 'APP_DECISION_QUEUE' in os.environ else self.APP_DECISION_QUEUE
-        self.APP_RULES_QUEUE = os.getenv("APP_RULES_QUEUE") if 'APP_RULES_QUEUE' in os.environ else self.APP_RULES_QUEUE
 
         self.REDIS_HOST = os.getenv("REDIS_HOST") if 'REDIS_HOST' in os.environ else self.REDIS_HOST
         self.REDIS_PORT = os.getenv("REDIS_PORT") if 'REDIS_PORT' in os.environ else self.REDIS_PORT

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

@@ -16,6 +16,7 @@ def __init__(self, logger=None, repository=None):
         self.logger = logger if logger is not None else get_logger()
 
         self.repository = repository if repository is not None else OcorenRepository()
+        self.repository.debug = True
 
     def process(self, sqs_event):
         result = True
@@ -42,7 +43,10 @@ def process(self, sqs_event):
                     event_tracker.track(event_hash, event)
                     # todo implementar lógica aqui
                     # aqui temos um simples exemplo de created
+                    if 'data' in event:
+                        event = event['data']
                     event_vo = OcorenVO(event)
+                    self.logger.info('event_vo: {}'.format(event_vo.to_dict()))
                     created = self.repository.create(event_vo)
                     if not created:
                         result = False