setup registry_url, metrics_port, env vars and CLI args

brozzler/cli.py

@@ -165,6 +165,17 @@ def _get_help_string(self, action):
             return super()._get_help_string(action)
 
 
+class Env(str, enum.Enum):
+    """Values of the Prometheus ``env`` label applied to a
+    :py:class:`.Registration` indicating the deployment environment in which
+    the service being advertised is operating.
+    """
+
+    qa = "qa"
+    prod = "prod"
+    dev = "dev"
+
+
 def brozzle_page(argv=None):
     """
     Command line utility entry point for brozzling a single page. Opens url in
@@ -234,6 +245,24 @@ def brozzle_page(argv=None):
         action="store_true",
         help="Try to avoid web bot detection",
     )
+    arg_parser.add_argument(
+        "--registry_url",
+        dest="registry_url",
+        default=None,
+        help="Prometheus registry url",
+    )
+    arg_parser.add_argument(
+        "--metrics_port",
+        dest=metrics_port,
+        default=8889,
+        help="Prometheus metrics port",
+    )
+    arg_parser.add_argument(
+        "--env",
+        dest=env,
+        default=Env.dev,
+        help="Prometheus env value",
+    )
     arg_parser.add_argument(
         "--screenshot-full-page", dest="screenshot_full_page", action="store_true"
     )
@@ -279,6 +308,9 @@ def brozzle_page(argv=None):
         window_height=args.window_height,
         window_width=args.window_width,
         stealth=args.stealth,
+        registry_url=args.registry_url,
+        metrics_port=args.metrics_port,
+        env=args.env,
     )
 
     def on_screenshot(screenshot_jpeg):
@@ -517,6 +549,24 @@ def brozzler_worker(argv=None):
         action="store_true",
         help="Try to avoid web bot detection",
     )
+    arg_parser.add_argument(
+        "--registry_url",
+        dest="registry_url",
+        default=None,
+        help="Prometheus registry url",
+    )
+    arg_parser.add_argument(
+        "--metrics_port",
+        dest=metrics_port,
+        default=8888,
+        help="Prometheus metrics port",
+    )
+    arg_parser.add_argument(
+        "--env",
+        dest=env,
+        default=Env.qa,
+        help="Prometheus env value",
+    )
     add_common_options(arg_parser, argv)
 
     args = arg_parser.parse_args(args=argv[1:])
@@ -573,6 +623,9 @@ def get_skip_av_seeds():
         skip_visit_hashtags=args.skip_visit_hashtags,
         skip_youtube_dl=args.skip_youtube_dl,
         stealth=args.stealth,
+        registry_url=args.registry_url,
+        metrics_port=args.metrics_port,
+        env=args.env,
     )
 
     signal.signal(signal.SIGQUIT, dump_state)

brozzler/metrics.py

@@ -18,7 +18,7 @@
     class Env(str, enum.Enum):
         """Values of the Prometheus ``env`` label applied to a
         :py:class:`.Registration` indicating the deployment environment in which
-        the the service being advertised is operating.
+        the service being advertised is operating.
         """
 
         qa = "qa"

brozzler/worker.py

@@ -28,7 +28,6 @@
 import PIL.Image
 import io
 import socket
-import platform
 import random
 import requests
 import doublethink
@@ -42,18 +41,6 @@
 r = rdb.RethinkDB()
 
 
-# Setup metrics
-registry_url = None
-metrics_port = 8090
-env = metrics.Env.dev
-hostname = platform.node()
-if hostname.endswith("archive.org"):
-    registry_url = "http://wbgrp-svc283.us.archive.org:8888"
-    metrics_port = settings.metrics_port
-    env = metrics.Env.qa
-metrics.register_prom_metrics(registry_url, metrics_port, env)
-
-
 class BrozzlerWorker:
     logger = logging.getLogger(__module__ + "." + __qualname__)
 
@@ -85,6 +72,9 @@ def __init__(
         stealth=False,
         window_height=900,
         window_width=1400,
+        registry_url=None,
+        metrics_port=None,
+        env=None,
     ):
         self._frontier = frontier
         self._service_registry = service_registry
@@ -107,6 +97,9 @@ def __init__(
         self._window_height = window_height
         self._window_width = window_width
         self._stealth = stealth
+        self._registry_url = registry_url
+        self._metrics_port = metrics_port
+        self._env = env
 
         self._browser_pool = brozzler.browser.BrowserPool(
             max_browsers, chrome_exe=chrome_exe, ignore_cert_errors=True
@@ -118,6 +111,12 @@ def __init__(
         self._start_stop_lock = threading.Lock()
         self._shutdown = threading.Event()
 
+        # Setup metrics
+        registry_url = self._registry_url
+        metrics_port = self._metrics_port
+        env = self._env
+        metrics.register_prom_metrics(registry_url, metrics_port, env)
+
     def _choose_warcprox(self):
         warcproxes = self._service_registry.available_services("warcprox")
         if not warcproxes: