SSL KafkaAdminClient объект с использованием объекта java.security.Keystore

Один быстрый способ сделать это с помощью библиотеки pandas Python (версия 0.15 или выше работает лучше всего). Это приведет к созданию столбцов для вас - хотя, очевидно, выбор, который он делает для типов данных, может быть не таким, каким вы хотите. Если это не совсем то, что вы хотите, вы всегда можете использовать код «create table», сгенерированный как шаблон.

Вот простой пример:

import pandas as pd
df = pd.read_csv('mypath.csv')
df.columns = [c.lower() for c in df.columns] #postgres doesn't like capitals or spaces

from sqlalchemy import create_engine
engine = create_engine('postgresql://username:password@localhost:5432/dbname')

df.to_sql("my_table_name", engine)

И вот некоторые код, который показывает вам, как установить различные параметры:

#Set is so the raw sql output is logged
import logging
logging.basicConfig()
logging.getLogger('sqlalchemy.engine').setLevel(logging.INFO)

df.to_sql("my_table_name2", 
          engine, 
          if_exists="append",  #options are ‘fail’, ‘replace’, ‘append’, default ‘fail’
          index=False, #Do not output the index of the dataframe
          dtype={'col1': sqlalchemy.types.NUMERIC,
                 'col2': sqlalchemy.types.String}) #Datatypes should be [sqlalchemy types][1]
0
задан Giorgos Myrianthous 23 March 2019 в 00:04
поделиться

1 ответ

Кафка не поддерживает ssl использование объекта java.security.keystore. Вы можете заглянуть в класс SslFactory в kafka для получения дополнительной информации.

0
ответ дан Rohit Yadav 23 March 2019 в 00:04
поделиться
Другие вопросы по тегам:

Похожие вопросы: