这篇文章为大家详细介绍了为MongoDB数据库配置专有网络VPC以及Python3实现访问 MongoDB数据库的方法,文中示例代码非常详细,感兴趣的小伙伴们可以参考一下。
公共配置
创建专有网络VPC
- 登录 VPC控制台。
- 创建安全组
在安全组控制台 新建安全组,点击 创建安全组,设置安全组名称,网络类型选择 专有网络,并选择刚才创建的专有网络。
创建与配置 MongoDB 实例
- 创建成功后,在实例信息页面左侧的导航栏中单击白名单设置。
单击 default 区域框右侧的修改。
在弹出的对话框中,将函数计算所在的 VPC 网络的网段地址配置在白名单输入框中。
- 登录 VPC 控制台,在专有网络列表中找到应用所在的 VPC,单击该 VPC 的名称进入专有网络详情页面。
- 复制应用所在的 VPC 的 IPv4 网段。
- 在组内白名单设置框中粘贴该 VPC 的 IPv4 网段地址,然后单击确定。
最后访问 MongoDB 数据库 host 为实例的内网地址,可以登录阿里云控制台查看
函数计算配置 VPC
- 在 函数计算控制台 创建服务。
- 【专有网络配置】选项中,选择您在步骤一中创建的 VPC 网络,交换机、安全组。
- 【权限配置】选项中,选择【新建角色】,点击【点击授权】,在角色快速创建页面,点击【同意授权】。
- 这步的操作是授予函数计算对 ENI 的操作权限,函数计算访问 VPC 中资源需要的权限请参考文章 配置函数计算访问 VPC 内的资源
- 点击确定,新建服务完毕。
###函数编写与调试
下面演示 函数示例创建:
- 建立一个目录,用于存放代码和依赖模块,在该目录下新建 template.yml 文件,例如 /tmp/code/template.yml,内容为:
ROSTemplateFormatVersion: '2015-09-01'
Transform: 'Aliyun::Serverless-2018-04-03'
Resources:
MongoDB-test:
Type: 'Aliyun::Serverless::Service'
Properties:
Description: This is MongoDB service
Role: 'acs:ram::XXXX:role/fc-public-test'
LogConfig:
Project: XXX
Logstore: XXX
VpcConfig:
VpcId: vpc-XXXX
VSwitchIds:
- vsw-XXX
SecurityGroupId: sg-XXXX
InternetAccess: true
python-test:
Type: 'Aliyun::Serverless::Function'
Properties:
Handler: 'index.handler'
Runtime: python3
Timeout: 10
MemorySize: 128
CodeUri: './'
- 在该目录下创建 Funfile 文件内容为:
RUNTIME python3
RUN fun-install pip install pymongo
执行fun install
命令安装依赖:
$ fun install
using template: template.yml
start installing function dependencies without docker
安装过程。。。。
Install Success
在函数根目录下新建代码文件,例如 /tmp/code/index.py,在代码中使用 pymongo :
# -*- coding: utf-8 -*-
import uuid
from pymongo import MongoClient
def handler(event, context):
CONN_ADDR1 = 'dds-XXX.mongodb.rds.aliyuncs.com:3717'
CONN_ADDR2 = 'dds-XXXX.mongodb.rds.aliyuncs.com:3717'
REPLICAT_SET = 'XXX'
username = 'XXX'
password = 'XXXX'
#获取mongoclient
client = MongoClient([CONN_ADDR1, CONN_ADDR2], replicaSet=REPLICAT_SET)
#授权. 这里的user基于admin数据库授权
client.admin.authenticate(username, password)
#使用test数据库的collection:testColl做例子, 插入doc, 然后根据DEMO名查找
demo_name = 'python-' + str(uuid.uuid1())
print ('demo_name:'+ demo_name)
doc = dict(DEMO=demo_name, MESG="Hello ApsaraDB For MongoDB")
doc_id = client.test.testColl.insert(doc)
for d in client.test.testColl.find(dict(DEMO=demo_name)):
print ('find documents:'+ str(d))
return 'success'
使用 fun 工具部署:
$ fun deploy
using template: template.yml
using region: cn-hangzhou
using accountId: ***********3743
using accessKeyId: ***********Ptgk
using timeout: 60
部署过程。。。
function python-test deploy success
service MongoDB-test deploy success
登录控制台,即可看到相关的服务、函数被创建成功,且触发执行可以返回正确的结果。
以上就是为MongoDB数据库配置专有网络VPC以及Python3实现访问 MongoDB数据库的方法,如果想了解更多相关内容,欢迎关注天达云行业资讯频道!