Skip to content

session_user()

Описание

Функция session_user() возвращает имя пользователя текущей сессии Spark SQL. Это полезно для аудита и отслеживания, кто выполняет запросы.

Возвращаемое значение

Column - строка с именем пользователя текущей сессии

Пример использования

from pyspark.sql import SparkSession

# Создаем SparkSession
spark = SparkSession.builder.appName("session_user_example").getOrCreate()

# Получаем имя пользователя текущей сессии
current_user = spark.sql("SELECT session_user()").collect()[0][0]
print(f"Пользователь текущей сессии: {current_user}")

# Использование в DataFrame
df = spark.range(1)
df = df.withColumn("session_user", spark.sql("SELECT session_user()").collect()[0][0])
df.show()

Примечания

  • Возвращает имя пользователя, под которым выполняется текущая сессия
  • Может использоваться для аудита и контроля доступа
  • Связанные функции:
  • current_user() - синоним функции session_user()
  • user() - синоним функции session_user()