From 018d007750ff11349c27450a0a3e5940e2c5ad24 Mon Sep 17 00:00:00 2001 From: Tamer Ahmed Date: Wed, 26 Aug 2020 15:05:54 -0700 Subject: [PATCH] [cfggen] Use Redis Pipeline (#5250) This PR enables cfggen to readr/write from Redis DB using pipelines. Pipelines enables batch read/write from/to Redis DB. signed-off-by: Tamer Ahmed --- src/sonic-config-engine/sonic-cfggen | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/sonic-config-engine/sonic-cfggen b/src/sonic-config-engine/sonic-cfggen index c2b6248eae..a1ba825849 100755 --- a/src/sonic-config-engine/sonic-cfggen +++ b/src/sonic-config-engine/sonic-cfggen @@ -45,7 +45,7 @@ from sonic_py_common.device_info import get_platform, get_system_mac from sonic_py_common.multi_asic import get_asic_id_from_name, is_multi_asic, get_asic_device_id from config_samples import generate_sample_config from config_samples import get_available_config -from swsssdk import SonicV2Connector, ConfigDBConnector, SonicDBConfig +from swsssdk import SonicV2Connector, ConfigDBConnector, SonicDBConfig, ConfigDBPipeConnector from redis_bcc import RedisBytecodeCache from collections import OrderedDict from natsort import natsorted @@ -296,9 +296,9 @@ def main(): if args.from_db: if args.namespace is None: - configdb = ConfigDBConnector(**db_kwargs) + configdb = ConfigDBPipeConnector(use_unix_socket_path=True, **db_kwargs) else: - configdb = ConfigDBConnector(use_unix_socket_path=True, namespace=args.namespace, **db_kwargs) + configdb = ConfigDBPipeConnector(use_unix_socket_path=True, namespace=args.namespace, **db_kwargs) configdb.connect() deep_update(data, FormatConverter.db_to_output(configdb.get_config())) @@ -367,9 +367,9 @@ def main(): if args.write_to_db: if args.namespace is None: - configdb = ConfigDBConnector(**db_kwargs) + configdb = ConfigDBPipeConnector(use_unix_socket_path=True, **db_kwargs) else: - configdb = ConfigDBConnector(use_unix_socket_path=True, namespace=args.namespace, **db_kwargs) + configdb = ConfigDBPipeConnector(use_unix_socket_path=True, namespace=args.namespace, **db_kwargs) configdb.connect(False) configdb.mod_config(FormatConverter.output_to_db(data))