feat: unify telemetry instrumentation

* Move all telemetry initialization to media_tagging library
* Add logger and meter initialization

Change-Id: Ibf3f71fe7db612414b8e5d4971e634b2624f62c6

Author: AndreyMarkinPPC

libs/filonov/filonov/__init__.py

@@ -19,13 +19,17 @@
 Generates creative maps to be viewed via `https://filonov-ai.web.app/`.
 """
 
+import logging
+
 from filonov.creative_map import CreativeMap
 from filonov.filonov_service import (
   FilonovService,
   GenerateCreativeMapRequest,
   GenerateTablesRequest,
 )
 
+logging.getLogger(__name__).addHandler(logging.NullHandler())
+
 __all__ = [
   'FilonovService',
   'GenerateCreativeMapRequest',

libs/filonov/filonov/creative_map.py

@@ -37,6 +37,8 @@
 from filonov import previews
 from filonov.telemetry import tracer
 
+logger = logging.getLogger(__name__)
+
 MetricInfo: TypeAlias = dict[str, int | float]
 Info: TypeAlias = dict[str, int | float | str | list[str] | None]
 
@@ -229,13 +231,13 @@ def convert_report_to_media_info(
   if isinstance(media_type, str):
     media_type = media.MediaTypeEnum[media_type.upper()]
   if with_size_base and with_size_base not in performance.column_names:
-    logging.warning('Failed to set MediaInfo size to %s', with_size_base)
+    logger.warning('Failed to set MediaInfo size to %s', with_size_base)
     with_size_base = None
   if with_size_base:
     try:
       float(performance[0][with_size_base])
     except TypeError:
-      logging.warning('MediaInfo size attribute should be numeric')
+      logger.warning('MediaInfo size attribute should be numeric')
     with_size_base = None
 
   if modules:

libs/filonov/filonov/entrypoints/cli.py

@@ -27,15 +27,18 @@
 from media_fetching.sources import models
 from media_tagging import media
 from media_tagging.entrypoints import utils as tagging_utils
+from media_tagging.entrypoints.tracer import (
+  initialize_logger,
+  initialize_tracer,
+)
 from opentelemetry import trace
 from typing_extensions import Annotated
 
 import filonov
 from filonov.entrypoints import utils
-from filonov.entrypoints.tracer import initialize_tracer
 from filonov.telemetry import tracer
 
-initialize_tracer()
+initialize_tracer('filonov')
 typer_app = typer.Typer()
 
 Tagger = Annotated[
@@ -163,9 +166,11 @@ def main(
   ] = False,
 ):  # noqa: D103
   span = trace.get_current_span()
-  garf_utils.init_logging(
+  logger = garf_utils.init_logging(
     loglevel=loglevel.upper(), logger_type=logger, name=log_name
   )
+  logger.addHandler(initialize_logger('filonov'))
+
   supported_enrichers = (
     media_fetching.enrichers.enricher.AVAILABLE_MODULES.keys()
   )

libs/filonov/filonov/entrypoints/tracer.py

@@ -36,7 +36,7 @@
 from filonov import creative_map, exceptions
 from filonov.telemetry import tracer
 
-logger = logging.getLogger('filonov')
+logger = logging.getLogger(__name__)
 
 
 class SimilarityParameters(pydantic.BaseModel):

libs/filonov/filonov/filonov_service.py

@@ -40,6 +40,9 @@ ui = [
 playwright = [
   "playwright",
 ]
+gcp= [
+  "media-tagging[gcp]",
+]
 all = [
   "filonov[server,ui,playwright]"
 ]

libs/filonov/pyproject.toml

@@ -16,6 +16,8 @@
 
 # pylint: disable=C0330, g-bad-import-order, g-multiple-import
 
+import logging
+
 from media_fetching.media_fetching_service import MediaFetchingService
 from media_fetching.sources.dbm import BidManagerFetchingParameters
 from media_fetching.sources.fake import FakeFetchingParameters
@@ -27,6 +29,8 @@
 )
 from media_fetching.sources.youtube import YouTubeFetchingParameters
 
+logging.getLogger(__name__).addHandler(logging.NullHandler())
+
 __all__ = [
   'MediaFetchingService',
 ]

libs/media-fetching/media_fetching/__init__.py

@@ -23,11 +23,16 @@
 from garf.io import writer as garf_writer
 from media_tagging import media
 from media_tagging.entrypoints import utils as tagging_utils
+from media_tagging.entrypoints.tracer import (
+  initialize_logger,
+  initialize_tracer,
+)
 from typing_extensions import Annotated
 
 import media_fetching
 from media_fetching.sources import fetcher, models
 
+initialize_tracer('media-fetching')
 typer_app = typer.Typer()
 
 
@@ -112,9 +117,10 @@ def main(
     ),
   ] = False,
 ):  # noqa: D103
-  garf_utils.init_logging(
-    loglevel=loglevel.upper(), logger_type=logger, name=log_name
+  logger = garf_utils.init_logging(
+    logger_type=logger, loglevel=loglevel.upper(), name=log_name
   )
+  logger.addHandler(initialize_logger('media-fetching'))
 
   supported_enrichers = (
     media_fetching.enrichers.enricher.AVAILABLE_MODULES.keys()

libs/media-fetching/media_fetching/entrypoints/cli.py

@@ -31,7 +31,7 @@
 from media_fetching.sources import fetcher, models
 from media_fetching.telemetry import tracer
 
-logger = logging.getLogger('media-fetching')
+logger = logging.getLogger(__name__)
 
 
 class MediaFetchingService: