influxdata / influxdata/kapacitor
Does kapacitor filter data?
Open
- Dominant language
- Go
- Stars
- 2.4k
- Forks
- 479
- Avg merge
- 4d 16h
- Merged PRs (30d)
- 4
Description
I have the following tick script
stream
|from()
.database('manager')
.retentionPolicy('autogen')
.measurement('equity_summary')
|log()
|alert()
.id('{{ .TaskName }}')
.message('{{ .TaskName }} is {{ .Level }} value:{{ .Fields }}')
.warn(lambda:"volume"* I define the task by using this command
kapacitor define admin_test -type stream -dbrp manager.autogen -tick test
kapacitor enable admin_test
I write 10 points into kapacitor,but I feel curious about that there are only 3 points in
influxDB.
I read the log in /var/log/kapacitor/kapacitor.log and find that ten points are writen
into kapacitor seccessfully.Here are the points.
equity_summary uid=325,equity=110000,pos_profit=7865,margin=31423,commision=14813,settled_pl=30342,unsettled_pl=25344,pl=20548,volume=17774
equity_summary uid=244,equity=110000,pos_profit=30154,margin=17505,commision=11549,settled_pl=31868,unsettled_pl=28824,pl=18963,volume=28027
equity_summary uid=262,equity=110000,pos_profit=12580,margin=5859,commision=14633,settled_pl=27787,unsettled_pl=19480,pl=16245,volume=32102
equity_summary uid=450,equity=110000,pos_profit=2317,margin=9711,commision=21054,settled_pl=1968,unsettled_pl=21489,pl=5735,volume=26028
equity_summary uid=552,equity=110000,pos_profit=4407,margin=22013,commision=18926,settled_pl=14504,unsettled_pl=17058,pl=19581,volume=19353
equity_summary uid=28,equity=110000,pos_profit=17202,margin=32184,commision=7929,settled_pl=10095,unsettled_pl=31146,pl=10546,volume=24091
equity_summary uid=777,equity=110000,pos_profit=1403,margin=9873,commision=23252,settled_pl=16013,unsettled_pl=18468,pl=19048,volume=12253
equity_summary uid=48,equity=110000,pos_profit=26792,margin=28911,commision=8857,settled_pl=6818,unsettled_pl=12506,pl=18386,volume=13037
equity_summary uid=529,equity=110000,pos_profit=31304,margin=4413,commision=14483,settled_pl=31286,unsettled_pl=1050,pl=26561,volume=13466
equity_summary uid=316,equity=110000,pos_profit=17854,margin=749,commision=26843,settled_pl=9970,unsettled_pl=5331,pl=13645,volume=17766> select * from alert_test3
name: alert_test3
time commision equity margin pl pos_profit settled_pl uid unsettled_pl volume
---- --------- ------ ------ -- ---------- ---------- --- ------------ ------
2017-08-29T08:24:58.963007431Z 14813 110000 31423 20548 7865 30342 325 25344 17774
2017-08-29T08:25:06.976371898Z 14483 110000 4413 26561 31304 31286 529 1050 13466
2017-08-29T08:25:07.978105125Z 26843 110000 749 13645 17854 9970 316 5331 17766
Does kapacitor filter the other 7 points?
Contributor guide
Research direction
Start by reproducing the supplied stream task with the ten `equity_summary` points, using the shown `kapacitor define` and `kapacitor enable` commands. Compare the Kapacitor log with the `alert_test3` InfluxDB query and determine whether the missing points are filtered before `influxDBOut`; done means documenting the cause and expected behavior.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- go
- Domain
- observability, stream-processing
- Issue type
- Bug
- Difficulty
- 3/5
- Estimated time
- 1-2 days
- Activity status
- Stale
- Clarity
- Mostly clear
- Newbie friendliness
- 35/100