1. Učit se
    2. /
  2. Kurzy
    3. /
  3. Intermediate Object-Oriented Programming in Python
Connected

cvičení

Sestavení datového pipeline

Používání factory methods nejen zpřehledňuje kód, ale také usnadňuje jeho použití. V tomto příkladu si procvičíš vytvoření datového pipeline, který extrahuje data z databáze. Třída DataPipeline implementuje návrhový vzor factory method a je uvedena níže. Jako concrete products třídy Database jsou pro tebe také připraveny třídy Postgres a Redshift.

class DataPipeline:
  def _get_database(self, provider):
    if provider == "Postgres":
      return Postgres()
    elif provider == "Redshift":
      return Redshift()

  def extract_data(self, provider, query):
    database = self._get_database(provider)
    dataset = database.query_data(query)
    print(f"Extracted dataset from {provider} database")
    return dataset

Pokyny

100 XP
  • Vytvoř items_pipeline pomocí třídy DataPipeline a extrahuj dataset z databáze "Redshift" s dotazem SELECT * FROM items;.
  • Aktualizuj items_pipeline tak, aby místo toho načítal data z databáze "Postgres", přičemž použij stejný dotaz jako předtím.
  • Vytvoř etl_pipeline, který extrahuje data z "Redshift".