使用 Scala 记录消息日志

您可以使用 SLF4J API (http://www.slf4j.org/),将使用 Scala 编写的函数或过程处理程序发出的消息记录到日志中。当您 设置事件表 来存储日志条目时,Snowflake 会将处理程序代码生成的日志条目存储在表中。

您可以使用 Snowflake 上的 Snowflake 遥测库包含的 SLF4J API (http://www.slf4j.org/)。为此,请在创建函数或过程时,在 PACKAGES 子句中包含以下值:com.snowflake:telemetry:latest

有关使用 Maven 打包代码时包含遥测库的信息,请参阅 设置 Java 和 Scala 环境以使用遥测类

备注

使用 Snowflake 遥测库将其他库添加到函数或过程的执行环境中。有关更多信息,请参阅 Snowflake 遥测包依赖项

备注

SLF4J 不支持 FATAL 级别的日志记录消息。对于用 Java 或 Scala 编写的处理程序,FATAL 级别会被视为 ERROR 级别。

例如,如果将 LOG_LEVEL 参数设置为 FATAL,就会引入来自 Java 或 Scala 处理程序 ERROR 级别的消息。

有关在 Snowflake 中设置日志记录和检索消息的一般信息,请参阅 来自函数和过程的日志记录消息

通过代码记录之前,您必须:

  • 设置事件表来收集通过处理程序代码记录的消息。

    有关更多信息,请参阅 设置事件表

  • 确保您设置了日志记录级别,以便将所需的消息存储在事件表中。

    有关更多信息,请参阅 设置日志级别

Scala 示例

下面示例中的代码引用了 Snowflake 遥测库,并从中获取了一个日志记录器。它会在 INFO 级别记录一条消息。它还会记录一个异常错误。

有关可用于在特定级别记录日志的方法的更多信息,请参阅 SLF4J 方法 (https://www.slf4j.org/apidocs/org/slf4j/Logger.html)。

CREATE OR REPLACE PROCEDURE do_logging()
RETURNS VARCHAR
LANGUAGE SCALA
RUNTIME_VERSION = '2.12'
PACKAGES=('com.snowflake:snowpark:latest', 'com.snowflake:telemetry:latest')
HANDLER = 'ScalaLoggingHandler.doThings'
AS
$$
  import org.slf4j.Logger
  import org.slf4j.LoggerFactory
  import com.snowflake.snowpark.Session

  class ScalaLoggingHandler {
    private val logger: Logger = LoggerFactory.getLogger(getClass)

    logger.info("Logging from within the Scala constructor.")

    def doThings(session: Session): String = {
      logger.info("Logging from Scala method start.")

      try {
        throwException
      } catch {
        case e: Exception => logger.error("Logging an error from Scala handler: " + e.getMessage())
        return "ERROR"
      }
      return "SUCCESS"
    }

    // Simulate a thrown exception to catch.
    @throws(classOf[Exception])
    private def throwException = {
      throw new Exception("Something went wrong.")
    }
  }
$$
;
Copy

您可以通过对事件表执行 SELECT 命令,来访问日志消息。有关更多信息,请参阅 访问已记录消息的数据

以下示例中的代码查询存储日志消息的事件表。该查询报告处理程序类中每个日志条目的严重性和消息。

SET event_table_name='my_db.public.my_event_table';

SELECT
  RECORD['severity_text'] AS SEVERITY,
  VALUE AS MESSAGE
FROM
  IDENTIFIER($event_table_name)
WHERE
  SCOPE['name'] = 'ScalaLoggingHandler'
  AND RECORD_TYPE = 'LOG';
Copy

前面的示例生成以下输出。

---------------------------------------------------------------------------
| SEVERITY | MESSAGE                                                      |
---------------------------------------------------------------------------
| "INFO"   | "Logging from within the Scala constructor."                 |
---------------------------------------------------------------------------
| "INFO"   | "Logging from Scala method start."                           |
---------------------------------------------------------------------------
| "ERROR"  | "Logging an error from Scala handler: Something went wrong." |
---------------------------------------------------------------------------
语言: 中文