# #python #dataframe #google-cloud-dataflow #apache-beam
#питон #фрейм данных #google-облако-поток данных #апач-луч
Вопрос:
У меня есть входящий csv-файл с каким-то неизвестным заголовком. Я прочитал некоторые сопоставления из базы данных в конвейере.
Мне нужно переименовать заголовки, используя сопоставления, и в итоге получить схему, которая везде допускает значения null/none.
Я читаю в csv как фрейм данных, что здорово, а затем я натыкаюсь на стену — я мог бы легко выполнить df.переименование(столбцы=заголовки), но заголовки-это коллекция ПК, и, по-видимому, DataFrameTransform не очень хорошо работает с боковыми входами.
Кто-нибудь знает, как, черт возьми, я могу заставить эти две вещи хорошо играть? Спасибо