gitea_admin/sientia-dataops-opc-ingestor
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Atualiza o OPC Manager para incluir um intervalo de watchdog de 1 hora e define o nome do cliente como o ID do pod. Ajusta os testes para refletir essas mudanças na inicialização do cliente.

Browse Source
This commit is contained in:
Matheus
2025-09-03 11:47:47 -03:00
parent 28dd9eb5c7
commit 1eb5711345
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
ingestor/managers/opc_manager.py
View File

@@ -175,7 +175,8 @@ class OpcManager(BaseActivity):
metrics.OPC_CONNECTIONS_TOTAL.labels( metrics.OPC_CONNECTIONS_TOTAL.labels(
pod_id=self.pod_id, server_name=self.name).inc() pod_id=self.pod_id, server_name=self.name).inc()
try: try:
self.client = Client(self.url) self.client = Client(self.url, watchdog_intervall=3600000)
self.client.name = self.pod_id
if self.cert_path: if self.cert_path:
await self.set_security() await self.set_security()
self.logger.info(f'Starting connection to {self.name}...') self.logger.info(f'Starting connection to {self.name}...')

4
tests/unit/managers/test_opc_manager.py
View File

@@ -146,7 +146,7 @@ async def test_connect_no_security(client, mock_metrics, raw_opc_manager):
await raw_opc_manager.connect() await raw_opc_manager.connect()
client.assert_called_once_with(raw_opc_manager.url) client.assert_called_once_with(raw_opc_manager.url, watchdog_intervall=3600000)
raw_opc_manager.client.connect.assert_called_once() raw_opc_manager.client.connect.assert_called_once()
raw_opc_manager.set_security.assert_not_called() raw_opc_manager.set_security.assert_not_called()
mock_metrics.OPC_CONNECTIONS_TOTAL.labels.assert_called_once_with( mock_metrics.OPC_CONNECTIONS_TOTAL.labels.assert_called_once_with(
@@ -175,7 +175,7 @@ async def test_connect_with_security(client, raw_opc_manager):
await raw_opc_manager.connect() await raw_opc_manager.connect()
client.assert_called_once_with(raw_opc_manager.url) client.assert_called_once_with(raw_opc_manager.url, watchdog_intervall=3600000)
raw_opc_manager.client.connect.assert_called_once() raw_opc_manager.client.connect.assert_called_once()
raw_opc_manager.set_security.assert_called_once() raw_opc_manager.set_security.assert_called_once()