async def METHOD_NAME(self, query_expression, lastsortvalue=None, length=DEFAULT_LIMIT):
    headers = dict()
    headers['Content-Type'] = 'application/json'
    data = {
        "_source": {
            "includes": ["@timestamp", "source.*", "destination.*", "event.*", "client.*", "server.*", "observer.*",
                         "host.*", "network.*", "process.*", "user.*", "file.*", "url.*", "registry.*", "dns.*",
                         "tags"]
        },
        "size": length,
        "query": {
            "query_string": {
                "query": query_expression
            }
        },
        "sort": [
            {"@timestamp": "asc"},
        ]
    }
    if lastsortvalue:
        data["search_after"] = lastsortvalue
    self.logger.debug("URL endpoint: " + self.endpoint)
    self.logger.debug("URL data: " + json.dumps(data))
    return await self.client.call_api(self.endpoint, 'GET', headers, data=json.dumps(data), timeout=self.timeout)