テーブル値関数.python_worker_logs

Python ワーカーから収集されたログの DataFrame を返します。

構文

Python

spark.tvf.python_worker_logs()

パラメーター

この機能には問題はありません。

戻り値

pyspark.sql.DataFrame: Python ワーカーからのログを含む DataFrame。

例

Python

import pyspark.sql.functions as sf
import logging

@sf.udf("string")
def my_udf(x):
    logger = logging.getLogger("my_custom_logger")
    logger.warning("This is a warning")
    return str(x)

spark.conf.set("spark.sql.pyspark.worker.logging.enabled", "true")
spark.range(1).select(my_udf("id")).show()

Output

+----------+
|my_udf(id)|
+----------+
|         0|
+----------+

Python

import pyspark.sql.functions as sf
import logging

@sf.udf("string")
def my_udf(x):
    logger = logging.getLogger("my_custom_logger")
    logger.warning("This is a warning")
    return str(x)

spark.conf.set("spark.sql.pyspark.worker.logging.enabled", "true")
spark.range(1).select(my_udf("id")).show()
spark.tvf.python_worker_logs().select(
    "level", "msg", "context", "logger"
).show(truncate=False)

Output

+-------+-----------------+---------------------+----------------+
|level  |msg              |context              |logger          |
+-------+-----------------+---------------------+----------------+
|WARNING|This is a warning|{func_name -> my_udf}|my_custom_logger|
+-------+-----------------+---------------------+----------------+