Producer for PyF

producer.py

import os
import csv

f = os.path.join('/Users/ismail/sandbox/repos_own/pyf/','tmp.txt')

FIELDS = [
'A',
'B',
'C',
'D'
]

csv.register_dialect('tuk', delimiter='|', quoting=csv.QUOTE_NONE)
reader = csv.DictReader(f, fieldnames=FIELDS, dialect='tuk')

class Rec(object):
    def __init__(self, a, b, c, d):
        self.a = a
        self.b = b
        self.c = c
        self.d = d
    
def get_source():
    for row in reader:
        print row
        rec = Rec(row['a'],row['b'],
                   row['c'],row['d'])
        yield rec​​​​​​​​​​​