BaşlayınÜcretsiz Başlayın

Günlük kaydı pratiği

Aşağıdaki kod başlangıçta çalıştırılır:

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

Şimdi bu günlükleme işlemlerini pratik edeceksin.

Bu egzersiz

Python ile Spark SQL'e Giriş

kursunun bir parçasıdır
Kursu Görüntüle

Egzersiz talimatları

  • text_df sütunlarını bir debug mesajı olarak kaydet.
  • table1'in önbelleğe alınıp alınmadığını bir info mesajı olarak kaydet.
  • text_df'in ilk satırını bir warning mesajı olarak kaydet.
  • text_df'in seçili sütunlarını bir error mesajı olarak kaydet.

Uygulamalı interaktif egzersiz

Bu örnek kodu tamamlayarak bu egzersizi bitirin.

# 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"))
Kodu Düzenle ve Çalıştır