influxdata / influxdata/kapacitor
Help me! How to process each of the points
Nobody has claimed this yet.
- Dominant language
- Go
- Stars
- 2.4k
- Forks
- 479
- Avg merge
- 4d 16h
- Merged PRs (30d)
- 4
Description
How to process each of the points?
For example, such as the following TICKscript:
dbrp "line_data"."autogen"
batch
|query('''
select * from "line_data"."autogen"."warn" where time > now - 5s
''')
|window()
.period(5s)
.every(5s)
// process each points of the data set
|each()
// then alert each point
|alert()
.message('{{ index .Fileds "warn_msg" }}')
// publish to the mqtt topic
.mqtt('{{ .Name }}/{{ index .Tags "warn_level" }}')
// of the mqtt broker name
.brokerName('mqtt_broker')
.qos(0)
Does the TICKscript alert() each point or not?
Contributor guide
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Research direction
Start by reading the TICKscript example, focusing on how window(), each(), and alert() pass points through the pipeline. Determine whether alert() emits for each point, then document the observed behavior and any relevant processing assumptions so the question has a definitive answer.
Written by the indexing model from the issue text.
Assessment
- Domain
- stream-processing
- Issue type
- Documentation
- Difficulty
- 2/5
- Estimated time
- 1-3 hours
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100