forked from elastic/rally-tracks
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Added some ESQL queries to
elastic/logs (elastic#466)
* Added some ESQL queries to `elastic/logs` This dataset is of interest to ESQL particularly as we're targetting observability use cases. Currently ESQL is not mature enough to replace the workflows themselves, but can be used in the discover dashboard, and the queries chosen reflect possible usage in that dashboard, as well as investigating the impact of multiple grouping keys on similar aggregations. * Change test parameters to actually generate data The original parameters resulted in all indices completely empty (zero docs). Changing `start_date` and `end_date` to `bulk_start_date` and `bulk_end_date` resulted in only two indices getting data, the redis and k8s indices. Adding clients settings and increasing end date and max_generated_corpus_size results in all indices getting data, and reducing raw_data_volume_per_day increases data generation performance. These settings were chosen through trial and error to get the ESQL queries to actually run. Any smaller data sizes result in a `ValueSource mismatch` exception, likely due to some shards missing data. * Added one more ESQL query from observability set * Partial revert of index setup The fact that the tests actually use a different challenge for index setup and querying, allows for parameters much closer to the original. All we really needed was to index a full minnute instead of just 2s. * Minimise changes to logging-querying.json Some of the changes were useful only for local testing, so removing them.
- Loading branch information
1 parent
a030b3e
commit f22a9a2
Showing
4 changed files
with
120 additions
and
2 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,66 @@ | ||
| { | ||
| "name": "esql_basic_count_group_1", | ||
| "operation-type": "raw-request", | ||
| "method": "POST", | ||
| "path": "/_query", | ||
| "body": { | ||
| "query": "FROM logs-* | STATS count=count(*) BY agent.version | SORT count DESC | LIMIT 20" | ||
| } | ||
| }, | ||
| { | ||
| "name": "esql_basic_count_group_2", | ||
| "operation-type": "raw-request", | ||
| "method": "POST", | ||
| "path": "/_query", | ||
| "body": { | ||
| "query": "FROM logs-* | STATS count=count(*) BY agent.version, agent.type | SORT count DESC | LIMIT 20" | ||
| } | ||
| }, | ||
| { | ||
| "name": "esql_basic_count_group_3", | ||
| "operation-type": "raw-request", | ||
| "method": "POST", | ||
| "path": "/_query", | ||
| "body": { | ||
| "query": "FROM logs-* | STATS count=count(*) BY agent.version, agent.type, agent.hostname | SORT count DESC | LIMIT 20" | ||
| } | ||
| }, | ||
| { | ||
| "name": "esql_basic_count_group_4", | ||
| "operation-type": "raw-request", | ||
| "method": "POST", | ||
| "path": "/_query", | ||
| "body": { | ||
| "query": "FROM logs-* | STATS count=count(*) BY agent.version, agent.type, agent.hostname, agent.id | SORT count DESC | LIMIT 20" | ||
| } | ||
| }, | ||
| { | ||
| "name": "esql_time_range_and_date_histogram_two_groups_pre_filter", | ||
| "description": "Based on observability queries for average CPU over date histogram", | ||
| "operation-type": "raw-request", | ||
| "method": "POST", | ||
| "path": "/_query", | ||
| "body": { | ||
| "query": "FROM logs-* | EVAL start_time = DATE_PARSE(\"yyyy-MM-dd\",\"2020-01-01\"), end_time = DATE_PARSE(\"yyyy-MM-dd\",\"2020-01-02\") | WHERE @timestamp >= start_time AND @timestamp <= end_time AND http.response.body.bytes IS NOT NULL | EVAL bucket = DATE_TRUNC(1 hour, @timestamp) | STATS avg=AVG(http.response.body.bytes), min=MIN(http.response.body.bytes), max=MAX(http.response.body.bytes) BY data_stream.dataset, bucket | KEEP data_stream.dataset, bucket, min, avg, max" | ||
| } | ||
| }, | ||
| { | ||
| "name": "esql_time_range_and_date_histogram_two_groups_post_filter", | ||
| "description": "Based on observability queries for average CPU over date histogram", | ||
| "operation-type": "raw-request", | ||
| "method": "POST", | ||
| "path": "/_query", | ||
| "body": { | ||
| "query": "FROM logs-* | EVAL start_time = DATE_PARSE(\"yyyy-MM-dd\",\"2020-01-01\"), end_time = DATE_PARSE(\"yyyy-MM-dd\",\"2020-01-02\") | WHERE @timestamp >= start_time AND @timestamp <= end_time | EVAL bucket = DATE_TRUNC(1 hour, @timestamp) | STATS avg=AVG(http.response.body.bytes), min=MIN(http.response.body.bytes), max=MAX(http.response.body.bytes) BY data_stream.dataset, bucket | WHERE min IS NOT NULL | KEEP data_stream.dataset, bucket, min, avg, max" | ||
| } | ||
| }, | ||
| { | ||
| "name": "esql_dissect_duration_and_stats", | ||
| "description": "Based on observability queries for duration average", | ||
| "operation-type": "raw-request", | ||
| "method": "POST", | ||
| "path": "/_query", | ||
| "body": { | ||
| "query": "FROM logs-postgres* | DISSECT message \"duration: %{query_duration} ms\" | EVAL query_duration_num = TO_DOUBLE(query_duration) | STATS avg_duration = AVG(query_duration_num)" | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters