我正在使用Python创建一个简单的Azure函数。它只是简单地从Azure MySQL实例读取并将某些内容写回同一实例。但是,我无法成功连接到数据库。
import logging
from datetime import datetime
import azure.functions as func
import mysql.connector
from mysql.connector import errorcode
def connect_to_db():
logging.info(os.getcwd())
try:
db_conn = mysql.connector.connect(
user="...",
password='...',
host="....mysql.database.azure.com",
port=3306,
database='...'
)
return db_conn
except mysql.connector.Error as err:
if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:
logging.error("Something is wrong with your user name or password")
elif err.errno == errorcode.ER_BAD_DB_ERROR:
logging.error("Database does not exist")
else:
logging.error(err)
return None
def main(req: func.HttpRequest) -> func.HttpResponse:
logging.info('Python HTTP trigger function processed a request.')
db_conn = connect_to_db()
if db_conn:
logging.info('DB Connection is established {}'.format(db_conn))
else:
return func.HttpResponse(
"Azure Functions cannot connect to MySQL database.",
status_code=500
)
....
当我使用func host start
时,代码在我的本地计算机上运行良好,我也使用了相同的Azure MySQL实例。
但是,在我部署 Azure 函数后,它并非不起作用,并给我以下错误:
2055: Lost connection to MySQL server at '....mysql.database.azure.com:3306',
system error: 1 [SSL: WRONG_VERSION_NUMBER] wrong version number (_ssl.c:852)
我还尝试在 Azure 门户中禁用"强制 SSL",并启用了Allow access to Azure services
,这没有帮助。
任何帮助和意见将不胜感激!谢谢!
我最终自己解决了这个问题。
以下是步骤:
-
从 Azure 文档存储库下载 SSL 证书。你可以在这里得到它:https://learn.microsoft.com/en-us/azure/mysql/howto-configure-ssl
-
将证书文件与 Azure 函数项目放在一起。对我来说,我把它放在项目的根文件夹中,因为我在这个项目中可能会有多个需要此证书的功能
-
然后,获取python代码中的认证文件,如下所示
import pathlib def get_ssl_cert(): current_path = pathlib.Path(__file__).parent.parent return str(current_path / 'BaltimoreCyberTrustRoot.crt.pem')
-
因此,我可以在连接到MySQL时使用SSL证书
# Connect to MySQL cnx = mysql.connector.connect( user="ctao@azure-mysql-test", password='*******', host="azure-mysql-test.mysql.database.azure.com", port=3306, database='ciscoepcstats', ssl_ca=get_ssl_cert() )
附言由于安全问题,禁用SSL验证对我来说不是一个选择。但幸运的是,我找到了解决方案。
请按如下方式修改您的代码:
db_conn = mysql.connector.connect(
user="...",
password='...',
host="....mysql.database.azure.com",
port=3306,
database='...',
ssl_disabled=True
)
并将 Azure 门户上的 Azure Mysql 中的"强制 SSL 连接"状态更改为"已禁用"。