fix: some logs failing to upload

Closes #1

Author: Skelmis

logoo/__init__.py

@@ -4,7 +4,7 @@
 from .logger import Logger
 from .primary_logger import PrimaryLogger
 
-__version__ = "1.3.0"
+__version__ = "1.4.0"
 VersionInfo = namedtuple("VersionInfo", "major minor micro releaselevel serial")
-version_info = VersionInfo(major=1, minor=3, micro=0, releaselevel="final", serial=0)
+version_info = VersionInfo(major=1, minor=4, micro=0, releaselevel="final", serial=0)
 logging.getLogger(__name__).addHandler(logging.NullHandler())

logoo/logger.py

@@ -52,9 +52,9 @@ def log(
             "message": message,
             "source": self.name,
             "_timestamp.timezone": "UTC",
-            # We do this to get microseconds included
-            # Open to a better way to do it please
-            "_timestamp": str(created_at.timestamp()).replace(".", ""),
+            # We do this twice as OpenObserve will convert
+            # _timestamp to microseconds within their UI
+            "_timestamp": created_at.isoformat(),
             "_timestamp.iso_format": created_at.isoformat(),
         }
         if self.extra_metadata is not None:

logoo/primary_logger.py

@@ -141,11 +141,12 @@ async def _consume(self):
                             success = int(stream.get("successful", 0))
                             failure = int(stream.get("failed", 0))
                             log.debug(
-                                "Sent %s logs to stream %s. %s successful, %s failed",
+                                "Sent %s logs to stream %s. %s successful, %s failed%s",
                                 success + failure,
                                 stream.get("name"),
                                 success,
                                 failure,
+                                f'\n\tError: {stream.get("error")}' if stream.get("error") is not None else ""
                             )
 
                     else:

main.py

@@ -1,16 +1,21 @@
 import asyncio
+import logging
+import os
 
 from logoo import PrimaryLogger
 
+logging.basicConfig(level=logging.WARNING)
+logging.getLogger("logoo").setLevel(logging.DEBUG)
+
 
 async def main():
     logger: PrimaryLogger = PrimaryLogger(
         __name__,
-        base_url="",
-        org="",
-        stream="",
-        username="",
-        password="",
+        base_url=os.environ["URL"],
+        org=os.environ['ORG'],
+        stream=os.environ['STREAM'],
+        username=os.environ['USER'],
+        password=os.environ['PASS'],
         poll_time=5,
     )
     await logger.start_consumer()