ПочатиПочніть безкоштовно

Цільова таблиця

У попередніх вправах ви обчислили датафрейм recommendations. Він містить пари user_id і course_id з рейтингом, що відображає середню оцінку цього курсу. Припущення таке: курс із найвищою оцінкою, який підходить користувачеві, найкраще рекомендувати.

Час помістити цю таблицю в базу даних, щоб її могли використовувати кілька продуктів, наприклад механізм рекомендацій або система розсилок електронною поштою.

Оскільки це об'єкт pandas.DataFrame, можна використати метод .to_sql(). Звісно, спочатку потрібно під'єднатися до бази даних за допомогою URI з'єднання. Таблиця recommendations доступна у вашому середовищі.

Ця вправа є частиною курсу

Вступ до Data Engineering

Переглянути курс

Інструкції до вправи

  • Заповніть URI з'єднання для бази даних Postgres на хості localhost з портом 5432. Ви можете під'єднатися користувачем repl і паролем password. Назва бази даних — dwh.
  • Доповніть функцію load_to_dwh(). Вона має записувати в таблицю "recommendations" і замінювати таблицю, якщо вона вже існує.

Інтерактивна практична вправа

Спробуйте виконати цю вправу, доповнивши цей зразок коду.

connection_uri = "____://____:____@____:____/____"
db_engine = sqlalchemy.create_engine(connection_uri)

def load_to_dwh(recommendations):
    recommendations.____("____", ____, ____="____")
Редагувати та запускати код