当我想使用AWS BOTO3 python(在AWS Lambda上)连接并解析查询到RDS-MSSQL时,请帮助我修改代码
这是我的代码
import json
import boto3
database_name = database_name
db_cluster_arn = db_cluster_arn
query=query
rds_client=boto3.client('rds-data')
def execute_statement(sql):{
print('===== Example - Simple query =====')
response = rds_client.execute_statement(
database=database_name,
resourceArn=db_cluster_arn,
sql=sql
)
return response
response = execute_statement(query)
print(response['records'])
发现了两个问题。如果您修复了这些问题,它应该可以工作。
您{
在下面的行中有一个语法:
def execute_statement(sql):{
而且下面的行没有正确缩进。
response = execute_statement(query)
这是带有修复程序的代码:
import json
import boto3
database_name = 'HSA_NONSAN_PROD'
db_cluster_arn = 'arn:aws:rds:ap-southeast-1:499461857546:db:prod-hsaplus-db-2'
query='SELECT (CASE WHEN Status=1 THEN \'OK\' ELSE \'BAD\' END) AS Status FROM dbo.tbAllCustomer_NONSAN_JOBSTATUS WHERE JobRunNo=(SELECT MAX(JobRunNo) FROM dbo.tbAllCustomer_NONSAN_JOBSTATUS)'
rds_client=boto3.client('rds-data')
def execute_statement(sql):
print('===== Example - Simple query =====')
response = rds_client.execute_statement(
database=database_name,
resourceArn=db_cluster_arn,
sql=sql
)
return response
response = execute_statement(query)
print(response['records'])
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句