Aan de slagGa gratis aan de slag

Oefenen met logging

De volgende code wordt bij het opstarten uitgevoerd:

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

Je gaat nu deze logging-bewerkingen oefenen.

Deze oefening maakt deel uit van de cursus

Introductie tot Spark SQL in Python

Cursus bekijken

Oefeninstructies

  • Log de kolommen van text_df als debug-bericht.
  • Log of table1 in de cache staat als info-bericht.
  • Log de eerste rij van text_df als waarschuwing.
  • Log geselecteerde kolommen van text_df als foutbericht.

Praktische interactieve oefening

Probeer deze oefening eens door deze voorbeeldcode in te vullen.

# 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"))
Code bewerken en uitvoeren