session_endpoints

Creates, updates, deletes, gets or lists a session_endpoints resource.

Overview

Name	session_endpoints
Type	Resource
Id	aws.emr.session_endpoints

Fields

The following fields are returned by SELECT queries:

get_session_endpoint

Name	Datatype	Description
auth_token	string	A time-limited authentication token used to connect to the Spark Connect endpoint.
auth_token_expiration_time	string (date-time)	The time at which the authentication token expires. After this time, call GetSessionEndpoint again to obtain a new token.
credentials	object	Username and password used to authenticate with the Spark Connect server when connecting directly over VPC peering.
endpoint	string	The Spark Connect endpoint URL to use in the PySpark client. (pattern: <code>[\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*</code>)

Methods

The following methods are available for this resource:

Name	Accessible by	Required Params	Optional Params	Description
get_session_endpoint	select	region		Returns the Spark Connect endpoint URL and a time-limited authentication token for the specified session. Use the endpoint and token to connect a PySpark client to the session. Call this operation again when the token expires to obtain a new one.

Parameters

Parameters can be passed in the WHERE clause of a query. Check the Methods section to see which parameters are required or optional for each operation.

Name	Datatype	Description
region	string	AWS region (default: us-east-1)

SELECT examples

get_session_endpoint

Returns the Spark Connect endpoint URL and a time-limited authentication token for the specified session. Use the endpoint and token to connect a PySpark client to the session. Call this operation again when the token expires to obtain a new one.

SELECT
auth_token,
auth_token_expiration_time,
credentials,
endpoint
FROM aws.emr.session_endpoints
WHERE region = '{{ region }}' -- required
;