Панды: Как вставить фрейм данных в Clickhouse - PullRequest
Новая
       8

Панды: Как вставить фрейм данных в Clickhouse

0 голосов
/ 17 октября 2019

Я пытаюсь вставить фрейм данных Pandas в Clickhouse.

Это мой код 

import pandas
import sqlalchemy as sa

uri = 'clickhouse://default:@localhost/default'
ch_db = sa.create_engine(uri)

pdf = pandas.DataFrame.from_records([
    {'year': 1994, 'first_name': 'Vova'},
    {'year': 1995, 'first_name': 'Anja'},
    {'year': 1996, 'first_name': 'Vasja'},
    {'year': 1997, 'first_name': 'Petja'},
])

pdf.to_sql('test_humans', ch_db, if_exists='append', index=False)

И это ошибка, которую я получаю. Связано ли это с отсутствующими дополнительными аргументами относительно ДВИГАТЕЛЯ? Как я могу это исправить?

Исключение: код: 62, e.displayText () = DB :: Исключение: синтаксическая ошибка: сбой в позиции 65 (строка 7, столбец 2): FORMAT TabSeparatedWithNamesAndTypes. Ожидается одно из: ENGINE, определение хранилища (версия 19.15.2.2 (официальная сборка))

Ведение журнала

INFO: sqlalchemy.engine.base.Engine: EXISTS TABLE test_humansИНФОРМАЦИЯ: sqlalchemy.engine.base.Engine: {} ИНФОРМАЦИЯ: sqlalchemy.engine.base.Engine: CREATE TABLE test_humans (first_name TEXT, year BIGINT)

INFO: sqlalchemy.engine.base.Engine: {}ИНФОРМАЦИЯ: sqlalchemy.engine.base.Engine: ROLLBACK

...