-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathpreview_datafeed.yml
119 lines (112 loc) · 2.6 KB
/
preview_datafeed.yml
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
---
requires:
serverless: true
stack: true
---
teardown:
- do:
indices.delete: { index: airline-data }
- do:
ml.delete_job: { job_id: preview-datafeed-job }
---
setup:
- do:
indices.create:
index: airline-data
body:
mappings:
properties:
time:
type: date
airline:
type: keyword
responsetime:
type: float
event_rate:
type: integer
- do:
index:
index: airline-data
id: "1"
body: >
{
"time": "2017-02-18T00:00:00Z",
"airline": "foo",
"responsetime": 1.0,
"event_rate": 5
}
- do:
index:
index: airline-data
id: "2"
body: >
{
"time": "2017-02-18T00:30:00Z",
"airline": "foo",
"responsetime": 1.0,
"event_rate": 6
}
- do:
index:
index: airline-data
id: "3"
body: >
{
"time": "2017-02-18T01:00:00Z",
"airline": "bar",
"responsetime": 42.0,
"event_rate": 8
}
- do:
index:
index: airline-data
id: "4"
body: >
{
"time": "2017-02-18T01:01:00Z",
"airline": "foo",
"responsetime": 42.0,
"event_rate": 7
}
- do:
indices.refresh:
index: airline-data
---
"Test preview datafeed":
- do:
ml.put_job:
job_id: preview-datafeed-job
body: >
{
"analysis_config" : {
"bucket_span": "1h",
"detectors" :[{"function":"sum","field_name":"responsetime","by_field_name":"airline"}]
},
"data_description" : {
"time_field":"time"
}
}
- do:
ml.put_datafeed:
datafeed_id: preview-datafeed-feed
body: >
{
"job_id":"preview-datafeed-job",
"indexes":"airline-data"
}
- do:
ml.preview_datafeed:
datafeed_id: preview-datafeed-feed
- length: { $body: 4 }
- match: { 0.time: 1487376000000 }
- match: { 0.airline: foo }
- match: { 0.responsetime: 1.0 }
- match: { 1.time: 1487377800000 }
- match: { 1.airline: foo }
- match: { 1.responsetime: 1.0 }
- match: { 2.time: 1487379600000 }
- match: { 2.airline: bar }
- match: { 2.responsetime: 42.0 }
- match: { 3.time: 1487379660000 }
- match: { 3.airline: foo }
- match: { 3.responsetime: 42.0 }