SageMakerStudioDataEngineeringSessions
SageMaker Unified Studio Data Engineering Sessions
This pacakge depends on SageMaker Unified Studio environment, if you are using SageMaker Unified Studio, see AWS Doc for guidance.
This package contains functionality to support SageMaker Unified Studio connecting to various AWS Compute including EMR/EMR Serverless/Glue/Redshift etc.
It is utilizing ipython magics and AWS DataZone Connections to achieve the following features.
Features
- Connect to remote compute
- Execute Spark code in remote compute in Python/Scala
- Execute SQL queries in remote compute
- Send local variables to remote compute
How to setup
If you are using SageMaker Unifed Studio, you can skip this part, SageMaker Unifed Studio already set up the package.
This package contains various Jupyter Magics to achieve its functionality.
To load these magics, make sure you have iPython config file generated. If not, you could run ipython profile create, then a file with path ~/.ipython/profile_default/ipython_config.py should be generated
Then you will need to add the following line in the end of that config file
c.InteractiveShellApp.extensions.extend(['sagemaker_studio_dataengineering_sessions.sagemaker_connection_magic'])
Once that is finished, you could restart the ipython kernel and run %help to see a list of supported magics
Interactive vs background session
This packages uses SM_INPUT_NOTEBOOK_NAME environment variable to determine if the execution is through interactive or background session. See sagemaker_studio_dataengineering_sessions/sagemaker_database_session_manager/redshift/redshift_session.py file for usage.
Examples
To connect to remote compute, a DataZone Connection is required, you could create it via CreateConnection API, Let's say there's an existing connection called project.spark.
Supported Connection Type:
- IAM
- SPARK
- REDSHIFT
- ATHENA
Connect to remote compute and Execute Spark Code in Python
The following example will connect to AWS Glue Interactive session and run the spark code in Glue.
%%pyspark project.spark
import sys
import boto3
from awsglue.utils import getResolvedOptions
from pyspark.context import SparkContext
from pyspark.sql import SparkSession
from pyspark.sql.functions import col
args = getResolvedOptions(sys.argv, ["redshift_url", "redshift_iam_role", "redshift_tempdir","redshift_jdbc_iam_url"])
print(f"{args}")
sc = SparkContext.getOrCreate()
spark = SparkSession(sc)
df = spark.read.csv(f"s3://sagemaker-example-files-prod-{boto3.session.Session().region_name}/datasets/tabular/dirty-titanic/", header=True)
df.show(5, truncate=False)
df.printSchema()
df.createOrReplaceTempView("df_sql_tempview")
Execute Spark Code in Scala
The following example will connect to AWS Glue Interactive session and run the spark code in Scala.
%%scalaspark project.spark
val dfScala = spark.sql("SELECT count(0) FROM df_sql_tempview")
dfScala.show()
Execute SQL query in remote compute
The following example will connect to AWS Glue Interactive session and run the spark code in Scala.
%%sql project.redshift
select current_user()
Some other helpful magics
%help - list available magics and related information
%send_to_remote - send local variable to remote compute
%%configure - configure spark application config in remote compute
1 maintainer
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file sagemaker_studio_dataengineering_sessions-1.3.25.tar.gz.
File metadata
- Download URL: sagemaker_studio_dataengineering_sessions-1.3.25.tar.gz
- Upload date:
- Size: 274.9 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/7.0.0 CPython/3.10.12
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
3bcfc28735bca1d1b192dc00a4dd5f8378191d9eb6a5bd1c7ab6f2d3f6e9c36c
|
|
| MD5 |
26b2840c312deab606b292c33af15d04
|
|
| BLAKE2b-256 |
da5b47ce35c02b77c3d80f648a460e6922b85112041707b6e15da1c2ad6b2a1c
|
File details
Details for the file sagemaker_studio_dataengineering_sessions-1.3.25-py3-none-any.whl.
File metadata
- Download URL: sagemaker_studio_dataengineering_sessions-1.3.25-py3-none-any.whl
- Upload date:
- Size: 339.2 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/7.0.0 CPython/3.10.12
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
5694931b70ccae840a432ce9b0b9ad3c934e29cd735fcd124a7d03e2472856cf
|
|
| MD5 |
d32e034fa3c9fdc8e29b529f6641a68f
|
|
| BLAKE2b-256 |
5be7aa2641b5da03737bfa360a5dea7230a736cbd5ceb3ce5b639390caa85df3
|
