代码示例: 在编写 AWS Glue 作业时,可以使用以下代码确认连接是否成功:
import sys from awsglue.utils import getResolvedOptions from pyspark.sql import SparkSession
spark = SparkSession.builder.getOrCreate()
connection_name = "database_connection_name"
args = getResolvedOptions(sys.argv, ["JOB_NAME"])
try:
connection = spark.read.format("jdbc")
.option("url", f"jdbc:postgresql://{connection_name}.**********.rds.amazonaws.com:5432/yourdatabase")
.option("user", "yourusername")
.option("password", "yourpassword")
.option("driver", "org.postgresql.Driver")
.load()
print("Connection successful")
except:
print("Connection failed")
上一篇:AWSGlue跨区域连接
下一篇:AWSGlue连接到S3失败