example scripts

tap_example Module

Uses stream tap to get information from a stream of data in csv files.

tap_example.certain_kind_tap(data_items)

Parameters:data_items – A sequence of unicode strings

tap_example.get_fruit(item)

Get things that are fruit.

Returns:thing of item if it’s a fruit

tap_example.get_metal(item)

Get things that are metal.

Returns:thing of item if it’s metal

tap_example.run()

Run the composition of csv_file_consumer and information tap with the csv files in the input directory, and collect the results from each file and merge them together, printing both kinds of results.