ÎncepețiÎncepe gratuit

Exersează jurnalizarea

Următorul cod este executat la pornire:

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

Acum vei exersa aceste operațiuni de jurnalizare.

Acest exercițiu face parte din cursul

Introducere în Spark SQL în Python

Vezi cursul

Instrucțiuni pentru exercițiu

  • Jurnalizează coloanele din text_df ca mesaj de debug.
  • Jurnalizează dacă table1 este memorată în cache ca mesaj de info.
  • Jurnalizează primul rând din text_df ca mesaj de warning.
  • Jurnalizează coloanele selectate din text_df ca mesaj de error.

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

# 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"))
Editează și rulează codul