Skip to content

Commit

Permalink
Bring CSV enrichment example up-to-date
Browse files Browse the repository at this point in the history
Signed-off-by: Jesse Szwedko <[email protected]>
  • Loading branch information
jszwedko committed Nov 8, 2022
1 parent 08b8574 commit d043aa5
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions csv-enrichment/vector.toml
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ interval = 2

# Generate coded error messages
[sources.coded_error_messages]
type = "generator"
type = "demo_logs"
format = "shuffle"
lines = [
'{"code":1,"device_id":"e5ad503d","timestamp":"2021-10-18T15:35:09.158139Z"}',
Expand All @@ -47,22 +47,22 @@ interval = 2
type = "remap"
inputs = ["user_info_messages"]
source = """
. = parse_json(.message) ?? {}
. = object!(parse_json(.message) ?? {})
. |= get_enrichment_table_record("users", { "last_name": .last_name, "first_name": .first_name }) ?? {}
"""

[transforms.remap_coded_errors]
type = "remap"
inputs = ["coded_error_messages"]
source = """
. = parse_json!(.message)
. = object!(parse_json(.message) ?? {})
row, err = get_enrichment_table_record("codes", { "code": del(.code) })
if err != null {
log(err, level: "error")
} else {
. |= merge(., {"message": row.message, "tag": row.tag})
. |= {"message": row.message, "tag": row.tag}
}
"""

Expand Down

0 comments on commit d043aa5

Please sign in to comment.