code: 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