Kom igångKom igång gratis

Öva på loggning

Följande kod körs vid uppstart:

import logging
logging.basicConfig(stream=sys.stdout, level=logging.DEBUG,
                    format='%(levelname)s - %(message)s')

Nu ska du öva på dessa loggningsoperationer.

Den här övningen är en del av kursen

Introduktion till Spark SQL i Python

Visa kurs

Övningsinstruktioner

  • Logga kolumnerna i text_df som ett debugmeddelande.
  • Logga om table1 är cachad som ett infomeddelande.
  • Logga första raden i text_df som ett varningsmeddelande.
  • Logga utvalda kolumner i text_df som ett felmeddelande.

Interaktiv övning med praktiskt arbete

Testa den här övningen genom att slutföra den här exempelkoden.

# Log columns of text_df as debug message
____("text_df columns: %s", text_df.columns)

# Log whether table1 is cached as info message
____("table1 is cached: %s", spark.catalog.isCached(tableName="table1"))

# Log first row of text_df as warning message
____("The first row of text_df:\n %s", text_df.first())

# Log selected columns of text_df as error message
____("Selected columns: %s", text_df.select("id", "word"))
Redigera och kör kod