Я использую Bonobo для базового преобразования и загрузки
- Я получаю данные в кадре данных
- Доходность одного ряда
- Нормализация одного ряда
- Загрузить одну строку в базу данных
def get_graph(**options):
graph = bonobo.Graph()
graph.add_chain(
transform(data_as_dataframe),
normalize,
load
)
return graph
graph = get_graph()
bonobo.run(graph)
Процесс кажется очень медленным (пять минут для 1000 строк / 20 столбцов).
Бонобо использует многопоточность под капотом?
Есть мысли о том, почему загрузка этого небольшого набора данных займет так много времени?
Может кто-нибудь привести пример того, как сделать нечто подобное?
Спасибо