code: def _mds_rpc_post(self, device_id, _wrap_with_consumer=True, async_id=None, **params):
          
          self.ensure_notifications_thread()
          api = self._get_api(mds.DeviceRequestsApi)
          async_id = async_id or utils.new_async_id()
          device_request = mds.DeviceRequest(**params)
          api.create_async_request(
              device_id,
              async_id=async_id,
              body=device_request,
          )
          return AsyncConsumer(async_id, self._db) if _wrap_with_consumer else async_id
docs: Helper for using RPC endpoint