From 0af65d36d2d770b5cfd0a822e55732b664e73f97 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=AD=99=E6=B0=B8=E5=BC=BA?= <11704063+s-yongqiang@user.noreply.gitee.com> Date: Mon, 6 Jan 2025 11:54:06 +0800 Subject: [PATCH] update metric channel name --- events/metrics.py | 8 ++++---- seafevent_server/request_handler.py | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/events/metrics.py b/events/metrics.py index b5316150..ec2eb621 100644 --- a/events/metrics.py +++ b/events/metrics.py @@ -11,7 +11,7 @@ local_metric = {'metrics': {}} NODE_NAME = os.environ.get('NODE_NAME', 'default') - +METRIC_CHANNEL_NAME = "metic-channel" ### metrics decorator def seasearch_index_timing_decorator(func): @@ -31,7 +31,7 @@ def wrapper(*args, **kwargs): duration_seconds = end_time - start_time publish_metric['metric_value'] = round(duration_seconds, 3) if ENABLE_METRIC: - redis_client.publish("metric-channel", json.dumps(publish_metric)) + redis_client.publish(METRIC_CHANNEL_NAME, json.dumps(publish_metric)) return wrapper @@ -75,7 +75,7 @@ def __init__(self, app, config): def run(self): logging.info('Starting handle redis channel') - subscriber = self._redis_client.get_subscriber('metric-channel') + subscriber = self._redis_client.get_subscriber(METRIC_CHANNEL_NAME) while not self._finished.is_set(): try: @@ -94,7 +94,7 @@ def run(self): time.sleep(0.5) except Exception as e: logging.error('Failed handle metrics: %s' % e) - subscriber = self._redis_client.get_subscriber('metric-channel') + subscriber = self._redis_client.get_subscriber(METRIC_CHANNEL_NAME) class MetricRedisRecorder(object): diff --git a/seafevent_server/request_handler.py b/seafevent_server/request_handler.py index 20f8a8f5..6260b352 100644 --- a/seafevent_server/request_handler.py +++ b/seafevent_server/request_handler.py @@ -11,7 +11,7 @@ from seafevents.repo_metadata.metadata_server_api import MetadataServerAPI from seafevents.repo_metadata.utils import add_file_details from seafevents.app.event_redis import redis_cache -from seafevents.events.metrics import NODE_NAME +from seafevents.events.metrics import NODE_NAME, METRIC_CHANNEL_NAME @@ -30,7 +30,7 @@ def publish_io_qsize_metric(qsize): } } if ENABLE_METRIC: - redis_cache.publish('metric-channel', json.dumps(publish_metric)) + redis_cache.publish(METRIC_CHANNEL_NAME, json.dumps(publish_metric)) def check_auth_token(req):