async def METHOD_NAME(self, params: ua.CreateMonitoredItemsParameters):
    self.logger.info("create monitored items")
    if params.SubscriptionId not in self.subscriptions:
        res = []
        for _ in params.ItemsToCreate:
            response = ua.MonitoredItemCreateResult()
            response.StatusCode = ua.StatusCode(ua.StatusCodes.BadSubscriptionIdInvalid)
            res.append(response)
        return res
    return await self.subscriptions[params.SubscriptionId].monitored_item_srv.METHOD_NAME(params)