[BUG] Issues with multiple instances of OPC-UA connector

[TheBergam]

In my setup, I have the thingsboard gateway connecting to 12 separate OPC-UA servers, monitoring around 150 tags each.
Each OPC-UA server has the same variable names but they will be sent to different thingsboard devices (e.g. OPC-UA server 1 has a temperature tag that will go to thingsboard device temperature01 and OPC-UA server 2 has a temperature tag that will go to thingsboard device temperature02).

I'm using the OPC-UA assyncio connector, and in my tb_gateway.yaml file I had something like this:

connectors:
 -
   name: OPC-UA Connector 01
   type: opcua_asyncio
   configuration: opcua_01.json
 -
   name: OPC-UA Connector 02
   type: opcua_asyncio
   configuration: opcua_02.json
(...)
 -
   name: OPC-UA Connector 12
   type: opcua_asyncio
   configuration: opcua_12.json

With this setup, the different connectors were sending data to the wrong devices.
I arrived to the conclusion that it was because of the following connector class variables:

thingsboard-gateway/thingsboard_gateway/connectors/opcua_asyncio/opcua_connector.py

Lines 49 to 51 in 114a33d

	class OpcUaConnectorAsyncIO(Connector, Thread):
	DATA_TO_SEND = Queue(-1)
	SUB_DATA_TO_CONVERT = Queue(-1)

Since DATA_TO_SEND and SUB_DATA_TO_CONVERT are defined outside the methods, they are accessible by all instances of class OpcUaConnectorAsyncIO

Instead of each connector having their own queue, they are accessing the same queues, and a given connector is not checking if the element of the queue they are processing is supposed to be processed by them.

The solution I found was to create a different custom opcua connector for each connection (e.g. CustomOpcUaConnector01, CustomOpcUaConnector02 ... CustomOpcUaConnector12) so that each connector would have its own DATA_TO_SEND and SUB_DATA_TO_CONVERT queues.

Is this something that can be fixed in a new release in order to avoid needing to use a custom connector for each opcua server?
Is there a better way to work around this?

Connector name:

• OPC-UA Connector assyncio

Versions:

• OS: Debian GNU/Linux 11 (bullseye)
• Thingsboard IoT Gateway version: 3.1
• Python version: 3.9.2

[samson0v]

Hi @TheBergam, we will fix it in the nearest future.