code: async def connect_message(self, message, context):
          
          conn_string = message.get('connection_string')
          client_id = context.user_data
  
          await self.connect(client_id, conn_string)
docs: Handle a connect message.
  
          See :meth:`AbstractDeviceAdapter.connect`.