Создание функций для извлечения данных
При построении конвейера данных важно разбивать код на модули. Это делает конвейеры более читаемыми и пригодными для повторного использования, а также упрощает поиск и устранение неполадок. Создание и использование функций для отдельных операций в конвейере может даже пригодиться на старте нового проекта, задавая основу для дальнейшей разработки.
pandas импортирован как pd, а sqlalchemy готов к использованию.
Это упражнение является частью курса
ETL и ELT в Python
Интерактивное практическое упражнение
Попробуйте выполнить это упражнение, дополнив этот пример кода.
def extract():
# Create a connection URI and connection engine
connection_uri = "postgresql+psycopg2://repl:password@localhost:____/____"
db_engine = sqlalchemy.____(connection_uri)