Skip to content

Commit 029e667

Browse files
committed
Configure redis parameters via envs
1 parent 2c7e7de commit 029e667

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

stream_simulator/connectivity/commlib_factory.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,12 @@ def __init__(self, *args, **kwargs): # pylint: disable=unused-argument
119119
)
120120
self._logger.info("Using MQTT connection parameters")
121121
else:
122-
self.conn_params = RedisConnectionParameters()
122+
self.conn_params = RedisConnectionParameters(
123+
host=os.getenv('REDIS_HOST', 'localhost'),
124+
port=os.getenv('REDIS_PORT', '6379'),
125+
username=os.getenv('REDIS_USERNAME', ''),
126+
password=os.getenv('REDIS_PASSWORD', ''),
127+
)
123128
self._logger.info("Using Redis connection parameters")
124129

125130
super().__init__(

0 commit comments

Comments
 (0)