async def create(self, query, *, dc=None):
        if "Token" in query:
            query["Token"] = extract_attr(query["Token"], keys=["ID"])
        response = await self._api.post("/v1/query",
                                        params={"dc": dc}, data=query)
        return response.body