def readcsvfile(csvfile):
with open(csvfile, "r", newline="") as file:
reader = csv.DictReader(file, dialect = "excel", fieldnames=("timestamp", "sensor_id", "sensor_name", "value"))
- records = []
for row in reader:
- records.append(row)
- return records
+ yield row
def writesensordatadb(config, sensor_id, sensor_name, timestamp, value_type, value_raw, value):