Procvičování logování
Při spuštění se provede následující kód:
import logging
logging.basicConfig(stream=sys.stdout, level=logging.DEBUG,
format='%(levelname)s - %(message)s')
Teď si procvičíš různé operace logování.
Toto cvičení je součástí kurzu
Úvod do Spark SQL v Pythonu
Pokyny k cvičení
- Zaloguj sloupce
text_dfjako ladicí zprávu (debug). - Zaloguj, jestli je
table1uložena v mezipaměti, jako informační zprávu (info). - Zaloguj první řádek
text_dfjako varovnou zprávu (warning). - Zaloguj vybrané sloupce
text_dfjako chybovou zprávu (error).
Interaktivní cvičení na vyzkoušení si v praxi
Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.
# 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"))