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

fix: typo metadata support in csv parser (#10742)

This commit is contained in:
JackSharebourg 2022-02-28 15:21:47 +01:00 committed by GitHub
parent b12451b21a
commit c2458fe6b8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
plugins/parsers/csv/parser.go
View File

@ -39,8 +39,8 @@ type Parser struct {
SkipValues []string `toml:"csv_skip_values"` SkipValues []string `toml:"csv_skip_values"`
SkipErrors bool `toml:"csv_skip_errors"` SkipErrors bool `toml:"csv_skip_errors"`
MetadataRows int `toml:"csv_metadata_rows"` MetadataRows int `toml:"csv_metadata_rows"`
MetadataSeparators []string `toml:"cvs_metadata_separators"` MetadataSeparators []string `toml:"csv_metadata_separators"`
MetadataTrimSet string `toml:"cvs_metadata_trim_set"` MetadataTrimSet string `toml:"csv_metadata_trim_set"`
Log telegraf.Logger `toml:"-"` Log telegraf.Logger `toml:"-"`
metadataSeparatorList metadataPattern metadataSeparatorList metadataPattern
@ -75,7 +75,7 @@ func (p *Parser) initializeMetadataSeparators() error {
} }
if len(p.MetadataSeparators) == 0 { if len(p.MetadataSeparators) == 0 {
return fmt.Errorf("csv_metadata_separator required when specifying csv_metadata_rows") return fmt.Errorf("csv_metadata_separators required when specifying csv_metadata_rows")
} }
p.metadataSeparatorList = metadataPattern{} p.metadataSeparatorList = metadataPattern{}

2
plugins/parsers/csv/parser_test.go
View File

@ -844,7 +844,7 @@ func TestParseMetadataSeparators(t *testing.T) {
err = p.Init() err = p.Init()
require.Error(t, err) require.Error(t, err)
require.Equal(t, err.Error(), "initializing separators failed: "+ require.Equal(t, err.Error(), "initializing separators failed: "+
"csv_metadata_separator required when specifying csv_metadata_rows") "csv_metadata_separators required when specifying csv_metadata_rows")
p = &Parser{ p = &Parser{
ColumnNames: []string{"a", "b"}, ColumnNames: []string{"a", "b"},
MetadataRows: 1, MetadataRows: 1,