Logstash index to come from a csv field

Hello,
I have a field with columns A,B,C where A represents the source of the file.
Many sources send csv files to one location and the index should be according to the source.

For example:
file1.csv
A=source1 --> index should be "source1"

file2.csv
A=source2 --> index should be "source2"

Note that all rows in the csv file will contain the same info, so it's ok to choose any of the rows for creating the index.
Looks like the index is either hard-coded or derived from system fields, not from content fields. I hope it's possible because if not I'll have to engineer my solution completely differently and run multiple logstashes and separate every source to a separate location just to have separate indexes, which is a waste of resources.

Thanks in advance for any advice!
JD

If you create the A column into a field called (eg) source, then just do this in the output;

index => "%{source}-%{+YYYY.MM.dd}"

Thank you ! worked like a charm

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.