Получение значения по умолчанию в моем файле Avro для каждой записи - PullRequest
Новая
       4

Получение значения по умолчанию в моем файле Avro для каждой записи

0 голосов
/ 01 ноября 2019

Avro запись записана - когда я читаю ее обратно, она содержит значение по умолчанию для всех полей

, упрощенное до файла CSV с 3 записями 1,2,3 

 have a reader - i expect to see lines of 1 2 3 output - I get
    {'productName': 'NA'}
    {'productName': 'NA'}
    {'productName': 'NA'}

from fastavro import writer
    import os
    import csv
    WORKING_DIR = f"{os.path.expanduser('~/Documents')}"

    def csv_reader():
        with open(f'{WORKING_DIR}/2.csv') as f:
            reader = csv.DictReader(f)
            for row in reader:
                yield row



    schema = {
      "type": "record",
      "name": "dataset",
      "namespace": "com.example.avro",
      "doc": "Dataset1",
      "fields": [
        {
          "name": "productName",
          "doc": "",
          "type": "string",
          "default": "NA" }      
        ]
    }

    with open('export.avro', 'wb') as out:
        writer(out, schema, csv_reader())
...