Python, Bonobo, Etl, Python Programming, Data Pipeline.
get_graph(**options): graph = bonobo.Graph() # Extract from CSV file graph.add_chain(extract, transform) # Load into PostgreSQL database conn = psycopg2.connect(options['dsn']) graph.add_chain(load, args=(conn,)) return graph if __name__ == '__main__': options = { 'dsn': 'dbname=test user=test