microgue
Advanced tools
| Metadata-Version: 2.2 | ||
| Name: microgue | ||
| Version: 4.2.5 | ||
| Version: 4.2.6 | ||
| Summary: This project contains bootstrap code to speed up the development of AWS based microservices | ||
@@ -5,0 +5,0 @@ Author: Michael Hudelson |
@@ -33,7 +33,3 @@ import datetime | ||
| async def connect(self): | ||
| logger.debug(f"{self.__class__.__name__}.connect", priority=2) | ||
| try: | ||
| logger.debug("connecting to redis", priority=3) | ||
| logger.debug(f"host: {self.host}") | ||
| logger.debug(f"port: {self.port}") | ||
| self._cache_client = await redis.Redis( | ||
@@ -47,2 +43,4 @@ host=self.host, | ||
| logger.error(f"{self.__class__.__name__}.connect - error", priority=3) | ||
| logger.error(f"host: {self.host}") | ||
| logger.error(f"port: {self.port}") | ||
| logger.error(f"{e.__class__.__name__}: {str(e)}") | ||
@@ -49,0 +47,0 @@ if self.connection_required: |
@@ -20,7 +20,2 @@ import json | ||
| def __init__(self, *args, **kwargs): | ||
| logger.debug("connecting to eventbridge", priority=3) | ||
| logger.debug(f"event_bus_name: {self.event_bus_name}") | ||
| logger.debug(f"event_bus_region: {self.event_bus_region}") | ||
| async def publish(self, event_type, event_data=None): | ||
@@ -46,2 +41,4 @@ # defaults | ||
| logger.error(f"{self.__class__.__name__}.publish - error", priority=3) | ||
| logger.error(f"event_bus_name: {self.event_bus_name}") | ||
| logger.error(f"event_bus_region: {self.event_bus_region}") | ||
| logger.error(f"{e.__class__.__name__}: {str(e)}") | ||
@@ -51,7 +48,8 @@ raise PublishFailed(str(e)) | ||
| if response.get("ResponseMetadata", {}).get("HTTPStatusCode") == 200: | ||
| logger.debug(f"{self.__class__.__name__}.publish - success", priority=3) | ||
| return True | ||
| else: | ||
| logger.critical(f"{self.__class__.__name__}.publish - error", priority=3) | ||
| logger.critical(f"response: {response}") | ||
| logger.error(f"{self.__class__.__name__}.publish - error", priority=3) | ||
| logger.error(f"event_bus_name: {self.event_bus_name}") | ||
| logger.error(f"event_bus_region: {self.event_bus_region}") | ||
| logger.error(f"response: {response}") | ||
| raise PublishFailed(response) |
@@ -31,5 +31,2 @@ import json | ||
| def __init__(self, *args, **kwargs): | ||
| logger.debug("connecting to sqs", priority=3) | ||
| async def send(self, message): | ||
@@ -45,5 +42,5 @@ logger.debug(f"{self.__class__.__name__}.send", priority=2) | ||
| ) | ||
| logger.debug(f"{self.__class__.__name__}.send - success", priority=3) | ||
| except Exception as e: | ||
| logger.error(f"{self.__class__.__name__}.send - error", priority=3) | ||
| logger.error(f"queue_url: {self.queue_url}") | ||
| logger.error(f"{e.__class__.__name__}: {str(e)}") | ||
@@ -69,2 +66,3 @@ raise SendFailed(str(e)) | ||
| logger.error(f"{self.__class__.__name__}.receive - error", priority=3) | ||
| logger.error(f"queue_url: {self.queue_url}") | ||
| logger.error(f"{e.__class__.__name__}: {str(e)}") | ||
@@ -90,2 +88,3 @@ raise ReceiveFailed(str(e)) | ||
| logger.error(f"{self.__class__.__name__}.delete - error", priority=3) | ||
| logger.error(f"queue_url: {self.queue_url}") | ||
| logger.error(f"{e.__class__.__name__}: {str(e)}") | ||
@@ -92,0 +91,0 @@ raise DeleteFailed(str(e)) |
@@ -19,4 +19,2 @@ import json | ||
| async def get(self, secret_name): | ||
| logger.debug(f"{self.__class__.__name__}.get", priority=2) | ||
| logger.debug(f"secret_name: {secret_name}") | ||
| async with aioboto3.Session().client("secretsmanager") as secrets_client: | ||
@@ -29,2 +27,3 @@ try: | ||
| logger.error(f"{self.__class__.__name__}.get - error", priority=3) | ||
| logger.error(f"secret_name: {secret_name}") | ||
| logger.error(f"{e.__class__.__name__}: {str(e)}") | ||
@@ -31,0 +30,0 @@ raise GetSecretFailed(str(e)) |
@@ -35,6 +35,2 @@ import os | ||
| def __init__(self, *args, **kwargs): | ||
| logger.debug("connecting to s3", priority=3) | ||
| logger.debug(f"bucket_name: {self.bucket_name}") | ||
| async def upload(self, local_file_path, remote_file_path=None): | ||
@@ -53,2 +49,3 @@ async with aioboto3.Session().client("s3") as storage_client: | ||
| logger.error(f"{self.__class__.__name__}.upload - error", priority=3) | ||
| logger.error(f"bucket_name: {self.bucket_name}") | ||
| logger.error(f"{e.__class__.__name__}: {str(e)}") | ||
@@ -79,2 +76,3 @@ raise UploadFailed(str(e)) | ||
| logger.error(f"{self.__class__.__name__}.download - error", priority=3) | ||
| logger.error(f"bucket_name: {self.bucket_name}") | ||
| logger.error(f"{e.__class__.__name__}: {str(e)}") | ||
@@ -97,2 +95,3 @@ raise DownloadFailed(str(e)) | ||
| logger.error(f"{self.__class__.__name__}.delete - error", priority=3) | ||
| logger.error(f"bucket_name: {self.bucket_name}") | ||
| logger.error(f"{e.__class__.__name__}: {str(e)}") | ||
@@ -99,0 +98,0 @@ raise DeleteFailed(str(e)) |
+1
-1
| Metadata-Version: 2.2 | ||
| Name: microgue | ||
| Version: 4.2.5 | ||
| Version: 4.2.6 | ||
| Summary: This project contains bootstrap code to speed up the development of AWS based microservices | ||
@@ -5,0 +5,0 @@ Author: Michael Hudelson |
+1
-1
@@ -8,3 +8,3 @@ from setuptools import setup | ||
| name="microgue", | ||
| version="4.2.5", | ||
| version="4.2.6", | ||
| author="Michael Hudelson", | ||
@@ -11,0 +11,0 @@ author_email="michaelhudelson@gmail.com", |
Alert delta unavailable
Currently unable to show alert delta for PyPI packages.
90063
-0.2%1861
-0.21%