ฝึกใช้งาน Logging
โค้ดต่อไปนี้ถูกรันตั้งแต่เริ่มต้น:
import logging
logging.basicConfig(stream=sys.stdout, level=logging.DEBUG,
format='%(levelname)s - %(message)s')
ตอนนี้จะได้ฝึกใช้งานการบันทึก log แต่ละประเภท
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
Introduction to Spark SQL in Python
คำแนะนำการฝึกหัด
- บันทึกคอลัมน์ของ
text_dfเป็น debug message - บันทึกสถานะว่า
table1ถูก cache ไว้หรือไม่ เป็น info message - บันทึกแถวแรกของ
text_dfเป็น warning message - บันทึกคอลัมน์ที่เลือกจาก
text_dfเป็น error message
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ
ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์
# 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"))