Skip to content

Latest commit

 

History

History
30 lines (19 loc) · 693 Bytes

README.md

File metadata and controls

30 lines (19 loc) · 693 Bytes

Fluvio SmartModules

This smartmodule converts CSV records to JSON records.

You can test this smartmodule with the following steps:

$ fluvio cluster start 
$ smdk build
$ smdk load
$ fluvio topic create csv-json-topic
$ fluvio consume csv-json-topic --smartmodule=infinyon-labs/[email protected] -e delimiter=";" -e header_case=snake

In another terminal:

$ fluvio produce csv-json-topic -f ./test-data/semicolon-snake/input.csv --raw

Params

  • delimiter: The delimiter used in the CSV file. Default is ,.
  • header_case: The case of the header. Default is none. Possible values are snake, camel, none.

Tests

Checkout the makefile for the tests