Ошибка при преобразовании данных строки и массива из файла CSV в tfrecords - PullRequest
0 голосов
/ 19 апреля 2019

Я следую этим примерам, чтобы преобразовать мой CSV-файл в tfrecords.

Это код, который я пытался

csv = pd.read_csv("ehealth.csv").values
with tf.python_io.TFRecordWriter("ehealth.tfrecords") as writer:
    for row in csv:
        question, answer, question_bert, answer_bert = row[0], row[1] , row[1], row[2]
        example = tf.train.Example()
        example.features.feature["question"].bytes_list.value.extend(question.encode("utf8"))
        example.features.feature["answer"].bytes_list.value.extend(answer.encode("utf8"))
        example.features.feature["question_bert"].float_list.value.extend(question_bert)
        example.features.feature["answer_bert"].float_list.value.append(answer_bert)
        writer.write(example.SerializeToString())

Это моя ошибка

TypeError                                 Traceback (most recent call last) <ipython-input-36-0a8c5e073d84> in <module>()
      4         question, answer, question_bert, answer_bert = row[0], row[1] , row[1], row[2]
      5         example = tf.train.Example()
----> 6         example.features.feature["question"].bytes_list.value.extend(question.encode("utf8"))
      7         example.features.feature["answer"].bytes_list.value.extend(answer.encode("utf8"))
      8         example.features.feature["question_bert"].float_list.value.extend(question_bert)

TypeError: 104 has type int, but expected one of: bytes

Похоже, что существует проблема при кодировании строки.Я прокомментировал эти две строки, чтобы убедиться, что все остальное работает правильно,

csv = pd.read_csv("ehealth.csv").values
with tf.python_io.TFRecordWriter("ehealth.tfrecords") as writer:
    for row in csv:
        question, answer, question_bert, answer_bert = row[0], row[1] , row[1], row[2]
        example = tf.train.Example()
#         example.features.feature["question"].bytes_list.value.extend(question)
#         example.features.feature["answer"].bytes_list.value.extend(answer)
        example.features.feature["question_bert"].float_list.value.extend(question_bert)
        example.features.feature["answer_bert"].float_list.value.append(answer_bert)
        writer.write(example.SerializeToString())

, но затем я получаю эти ошибки

TypeError                                 Traceback (most recent call last) <ipython-input-13-565b43316ef5> in <module>()
      6 #         example.features.feature["question"].bytes_list.value.extend(question)
      7 #         example.features.feature["answer"].bytes_list.value.extend(answer)
----> 8         example.features.feature["question_bert"].float_list.value.extend(question_bert)
      9         example.features.feature["answer_bert"].float_list.value.append(answer_bert)
     10         writer.write(example.SerializeToString())

TypeError: 's' has type str, but expected one of: int, long, float

Оказывается, проблема в том, что панды интерпретируют мой массивв виде строки вместо массива

type( csv[0][2])

->str

Более того, похоже, что я должен использовать example.SerializeToString(), поскольку у меня есть массив, но я не уверен, как это сделать.

Ниже приведен полный код для воспроизведения ошибок, включая код, который загружает CSV-файл с диска Google.

import pandas as pd
import numpy as np
import requests
import tensorflow as tf

def download_file_from_google_drive(id, destination):
    URL = "https://docs.google.com/uc?export=download"

    session = requests.Session()

    response = session.get(URL, params = { 'id' : id }, stream = True)
    token = get_confirm_token(response)

    if token:
        params = { 'id' : id, 'confirm' : token }
        response = session.get(URL, params = params, stream = True)

    save_response_content(response, destination)    

def get_confirm_token(response):
    for key, value in response.cookies.items():
        if key.startswith('download_warning'):
            return value

    return None

def save_response_content(response, destination):
    CHUNK_SIZE = 32768

    with open(destination, "wb") as f:
        for chunk in response.iter_content(CHUNK_SIZE):
            if chunk: # filter out keep-alive new chunks
                f.write(chunk)

# download_file_from_google_drive('1rMjqKkMnt6_vROrGmlTGStNGmwPO4YFX', 'model.zip') #

file_id = '1anbEwfViu9Rzu7tWKgPb_We1EwbA4x1-'
destination = 'ehealth.csv'
download_file_from_google_drive(file_id, destination)

healthdata=pd.read_csv('ehealth.csv')
healthdata.head()

csv = pd.read_csv("ehealth.csv").values
with tf.python_io.TFRecordWriter("ehealth.tfrecords") as writer:
    for row in csv:
        question, answer, question_bert, answer_bert = row[0], row[1] , row[1], row[2]
        example = tf.train.Example()
        example.features.feature["question"].bytes_list.value.extend(question)
        example.features.feature["answer"].bytes_list.value.extend(answer)
        example.features.feature["question_bert"].float_list.value.extend(question_bert)
        example.features.feature["answer_bert"].float_list.value.append(answer_bert)
        writer.write(example.SerializeToString())


csv = pd.read_csv("ehealth.csv").values
with tf.python_io.TFRecordWriter("ehealth.tfrecords") as writer:
    for row in csv:
        question, answer, question_bert, answer_bert = row[0], row[1] , row[1], row[2]
        example = tf.train.Example()
#         example.features.feature["question"].bytes_list.value.extend(question)
#         example.features.feature["answer"].bytes_list.value.extend(answer)
        example.features.feature["question_bert"].float_list.value.extend(question_bert)
        example.features.feature["answer_bert"].float_list.value.append(answer_bert)
        writer.write(example.SerializeToString())

1 Ответ

2 голосов
/ 19 апреля 2019

Попробуйте

example.features.feature["question"].bytes_list.value.extend([bytes(question, 'utf-8')])

Это поможет вашей ошибке в строке 6, то же самое относится и к строке 7.

И проверьте свою нумерацию в

question, answer, question_bert, answer_bert = row[0], row[1] , row[1], row[2]

Iдумаю, это должно быть 0, 1, 2 и 3.

Исправляя правильное упорядочение, вы все равно получаете ошибку.Итак, добавьте

print(type(question_bert))

И он говорит, что это строка.Если это действительно строка, то вам нужно изменить на

float_list.value.append

на

bytes_list.value.extend

Если у вас есть массив, то вам нужно использовать

tf.serialize_tensor

Вот простой пример tf.serialize_tensor

a = np.array([[1.0, 2, 46], [0, 0, 1]])
b=tf.serialize_tensor(a)
b

Вывод

<tf.Tensor: id=25, shape=(), dtype=string, numpy=b'\x08\x02\x12\x08\x12\x02\x08\x02\x12\x02\x08\x03"0\x00\x00\x00\x00\x00\x00\xf0?\x00\x00\x00\x00\x00\x00\x00@\x00\x00\x00\x00\x00\x00G@\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\xf0?'>

Вы должны сохранить его в байтах.

...