CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add pivot example for starlark processor (#7976)

This commit is contained in:
Sam Dillard 2020-08-12 08:08:55 -07:00 committed by GitHub
parent 8878f3f311
commit 6c4636b860
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
plugins/processors/starlark/README.md
View File

@ -153,6 +153,7 @@ Attempting to modify the global scope will fail with an error.
- [rename](/plugins/processors/starlark/testdata/rename.star) - [rename](/plugins/processors/starlark/testdata/rename.star)
- [scale](/plugins/processors/starlark/testdata/scale.star) - [scale](/plugins/processors/starlark/testdata/scale.star)
- [number logic](/plugins/processors/starlark/testdata/number_logic.star) - [number logic](/plugins/processors/starlark/testdata/number_logic.star)
- [pivot](/plugins/processors/starlark/testdata/pivot.star)
Open a [PR](https://github.com/influxdata/telegraf/compare) to add any other useful Starlark examples. Open a [PR](https://github.com/influxdata/telegraf/compare) to add any other useful Starlark examples.

17
plugins/processors/starlark/testdata/pivot.star vendored Normal file
View File

@ -0,0 +1,17 @@
'''
Pivots a key's value to be the key for another key.
In this example it pivots the value of key `sensor`
to be the key of the value in key `value`
Input:
temperature sensor=001A0,value=111.48
Output:
temperature 001A0=111.48
'''
def apply(metric):
metric.fields[str(metric.fields['sensor'])] = metric.fields['value']
metric.fields.pop('value',None)
metric.fields.pop('sensor',None)
return metric