data_load.py

import brewery.stores as stores

filename = "data.csv"

source = stores.CSVDataSource(filename, encoding="latin1", infer_fields=True,
                                read_header=True)

target = stores.SQLDataTarget(url="sqlite:///data.sqlite",
                              table="data", create=True, fields=source.fields,
                              replace=True)

target.append_from(source)
target.flush()

data_transform.py

import brewery.stores as stores

filename = "data.csv"

source = stores.CSVDataSource(filename, encoding="latin1", infer_fields=True,
                                read_header=True)

target = stores.SQLDataTarget(url="sqlite:///data.sqlite",
                              table="data", create=True, fields=source.fields,
                              replace=True)

for row in source.rows()
    target.append(some_transformation(row))
target.flush()