# 获取当前数据库名称
```bash
db.getName()
```

# 创建数据库或选择数据库
```bash
use 数据库名
```

# 查看已有的数据库：
```bash
show dbs 或者 show dababase
```

# 删除数据库
```bash
use aa
db.goods.insert({'name':'zhangsan'})
show dbs
use aa
db.dropDatabse()
show dbs
```

# 查看数据状态
```bash
db.status()
```

# 简单运算
```bash
x=100
y=100
x+y
…………
```
# 查看数据库相关帮助信息
```bash
db.help()
```
# 集合的操作
```bash
// 查看当前数据库已有的集合
show tables
// 集合的创建
db.createCollection('goods')
//集合的删除
db.goods.drop()
```
# 集合的命名
1. 不能是空字符串(“ ”)
2. 不能包含\0字符(空字符)
3. 不能使用system.的前缀(系统保留)
4. 建议不包含保留字 ”$”
5. 用.分割不同命名空间的子集合(如：blog.users, blog.posts)

# 写入数据
```python
db.goods.insert({name:'huawei01',price:1000,weight:135,number:35})
```
>该_id字段的内容值 是mongodb本身算法获得出来的，该_id对应的值信息在”全球唯一”
相当于我们mysql表里的主键id,是唯一的。
好处：mongo的数据做升级、迁移比较方便
该_id可以自行设置，但是不推荐，但是现在版本升级以后，是不可以了，报语法的错误。

## 插入多条数据
```python
db.goods.insert([{},{},{}.......])
```
## 多维数据对象添加
```python
db.goods.insert({name:'xiaomi5',price:1999,weight:156,number:45,area:{province:'beijing',city:'beijing'}})
```

## 数组信息的添加
```python
db.goods.insert({name:'xiaomimax',price:2000,weight:180,number:100,area:{province:'beijing',city:'beijing'},color:['blank','white','red']})
```

## 保存数据
```python
db.hero.save({'_id':5,'name':'xiaohong'})
```
如果在保存数据的时候，所指定的id是存在的，则是修改数据：

# 数据查询
//查询数据表的全部数据
```python
db.数据表.find()

//查询数据表的第一条数据
db.数据表.findOne()
```
## 格式化输出
```bash
db.phthon.find().pertty()
```
# 范围条件查询

关键字：$gt   $lt    $gte   $lte
mysql关键字： >  <  >=  <=

> 查询价格大于1005元的商品
    db.goods.find({price:{‘$gt’:1005}})

# 限制查询字段
> db.表.find({条件},{字段：1/0,字段：1/0}

# 条件查询

    $or查询，多个条件，满足其一即可
    $in和$nin：
    $all 查询：表示完全匹配

# 自定义条件查询
```bash
db.good.find({'$where':function(){return this.price < 2000>}})
```
# 限制条数
```bash
db.good.find().limit(1)
```
# 跳过记录行数
```bash
db.godd.find().skip(1)
```
分页怎么写？
> limit(pageNow-1)*pageSize,2

# 排序
db.good.find().sort(['price',-1])
db.good.findOne({},sort=['price',-1])

# 数据去重
db.good.ditinct('去重名称',{条件})
> db.good.distinct("price",{number:1000})

# 修改数据
1. 有set的修改：只修改设置的字段，其他字段不变化
2. 没有set的修改：只修改设置的字段，没有修改的字段就删除了
db.集合名.update(条件，数据，[是否新增默认false],[是否修改多条默认false])
参数说明：
* 参数3，修改的数据不存在则自动添加，默认false，不添加。
* 参数4，是否修改所有符合条件的数据，默认false，只修改一条
# 删除数据
db.集合名.remove(query,justONe)
justOne：true/false是否只删除1条，默认为false,就是删除多条数据
# 删除字段
db.表.update({条件},{'$unset':{'字段':0/1}})
注意设置的字段0或者是1，都是可以进行删除此字段的
[中文文档](http://docs.mongoing.com/)

mongo命令界面操作

# 简单理解套接字

在任何类型的通信开始之前，网络应用程序都必须创建套接字
> 套接字最初是为同一主机上的应用程序所创建，使得主机上运行的一个程序（又名一个进程）与另一个运行的程序进行通信。这就是所谓的进程间的通信



有两种类型的套接字：基于文件和面向网络的：

1. 基于文件的  家族名:AF_UNIX

	它代表地址家族(addressfamily)：unix。其他比较旧的系统可能会将地址家族表示成域(domain)或协议家族(protocolfamily)
	
2. 面向网络的  家族名:AF_INET

	它代表地址家族(addressfamily)：因特网。另一个地址家族AF_INET6用于第6版因特网协议寻址。在所有的地址家族之中，目前AF_INET是使用最广泛的。
	
# 套接字地址：主机-端口对
做个比喻，套接字就像一个电话插孔，主机名和端口号就像区号和号码。当程序之间需要通信时，需要知道对端的主机名(IP)和端口号。有效的端口号范围为0~65535

# 面向连接的套接字与无连接的套接字
1. 面向连接的套接字
	
	TCP套接字的SOCK_STREAM
	特点：可靠，开销大
	> 在进行通信之前必须先建立一个连接，该连接的通信提供序列化的、可靠的和不重复的数据交付，而没有记录边界。这种类型的通信也称为虚拟电路或流套接字。

实现这种连接类型的主要协议是传输控制协议（缩写 TCP）
为了创建 TCP套接字，必须使用 SOCK_STREAM 作为套接字类型。

2. 无连接的套接字
	
	UDP套接字的名字SOCK_DGRAM
	特点:不可靠（局域网内还是比较可靠的）,开销小
	> 与虚拟电路形成鲜明对比的是数据报类型的套接字，它是一种无连接的套接字。

在通信开始之前并不需要建立连接。此时，在数据传输过程中并无法保证它的顺序性、可靠性或重复性。数据报确实保存了记录边界，这就意味着消息是以整体发送的，而并非首先分成多个片段。
实现这种连接类型的主要协议是用户数据报协议（缩写 UDP）。为
了创建UDP套接字，必须使用SOCK_DGRAM作为套接字类型。
UDP套接字的SOCK_DGRAM名字来自于单词“datagram”（数据报）。

简单理解套接字

## 1. 什么是申购费？
申购费是指投资者在基金成立后的存续期间，基金处于申购开放状态期内，向基金管理人购买基金份额时所支付的手续费。根据相关法规，申购费率不得超过申购金额的5%。目前申购费率通常在1.5%左右，并随申购金额的大小有相应的减让。

开放基金的申购金额里实际包括了申购费用和净申购金额两部分。申购费用可以按申购金额或净申购金额的一定比例计算。

申购费用=申购金额*适用的申购费率

净申购金额=申购金额-申购费用

申购份数=净申购金额-申购当日的基金单位净值



## 2. 什么是申购费率？
通俗地讲说申购费就是申购基金的手续费，按照一定的比例在你申购基金的资金扣除，比如你买一万元，则申购费=10000/(1+申购费率)，此费率一般基金公司已规定好，在募集公告中会有公布。

## 3. 什么是赎回费？
基金赎回费是指在开放式基金的存续期间，已持有基金单位的投资者向基金管理人卖出基金单位时所支付的手续费。通常赎回费计入基金资产。

计算公式：
* 赎回总额=赎回分数*赎回当日的基金单位净值
* 赎回费用=赎回总额*赎回费率
* 赎回金额=赎回总额-赎回费用

## 4. 什么是Carry？
Carry，是私募股权基金的核心激励机制，反映了基金投资人（GP）和出资人（LP）、GP内部之间的关系。最常见的模式是”2%+20%“，即一只基金在投资期时，LP支付给GP每年2%的管理费；存续期满后，基金的汇报达到了事先约定的底线后，GP将本金还给LP后，还可以分走利润的20%。这20%就是carry


买卖基金是要收手续费的，有两种收费方式：
1. 前端收费。买的时候收取申购费，卖的时候收取赎回费
2. 后端收费，买的时候不收取任何费用，卖的时候一起收取申购费和赎回费。但持有基金时间短于1年的话，后端费用比前端高。因而持有基金超过2年，选择后端收费模式才有意义。

## 5. 什么是前端佣金？
前端佣金，基金前端佣金。许多共同基金都要收取销售费用，称为佣金。前端佣金是买人佣金，从中购款中扣除。比如，前端佣金如果总投资额为10000美元，而佣金费率是8.5%，这样净投资额就是9150美元。前端佣金一些共同基金还索要后端佣金或者说是赎回费用，前端佣金这是投资者赎回基金份额时需要支付的费用。

## 6. 什么是投资标的？
意思是投资合同中当事人双方权力和义务所共同指向的对象，具体可以指某一投资项目，比如在P2P中，当借款人需要一笔资金去做生意，既可以通过平台这个中介集资，这就是一个项目，业内称为标

## 7. 什么是交割日期？
交割日期是指当选择权的买方要求选择权的卖方履行契约后，买卖双方依约分别支付对方所购买货币的日期

## 8. 什么是投资净值？
净值型理财产品，是指产品发行时未明确预期收益率，产品收益以净值的形式展示，投资者根据产品的实际运行情况，享受浮动收益的理财产品。分为封闭式净值型和开放式净值型产品；封闭式净值型产品是指产品期限固定，定期披露净值，投资者只能在产品到期时赎回；开放式理财产品是指产品在存续期内定期开放，投资者可以在开放期申购或赎回。

## 9.什么是客户退出净值？（换句话说，什么叫做净值？）
通俗地讲，净值就是去掉所有费用后剩下的金额。在不同的领域，净值的意义不同。

## 10. 什么是费前收益？
## 11. 什么是单位净值？
单位净值是指开放式基金申购份额及赎回金额计算的基础，即基金单位的净资产价值。

计算公式：单位净值=（基金资产总值-基金负债）/基金总份额。

股权投资基金的估值，是指通过对基金所持有的全部资产及应承担的全部负债按一定的原则和方法进行评估与计算，最终确定基金资产净值（NAV）的过程。

## 12. 什么是最新收盘价？
收盘价是指某种证券交易所一天交易活动结束前最后一笔交易的成交价格。如当日没有成交，则采用最近一次的成交价格作为收盘价，因为收盘价是当日行情的标准，又是下一个交易日开盘价的一句，可据以预测未来证券市场行情；所以投资者对行情分析时，一般次啊用收盘价作为计算依据。

## 13. 什么是认购费率？
就是投资者在新基金的募集期内购买基金份额时，基金公司按一定比率，向投资者收取的手续费。

## 14. 什么是管理费率？
为基金提供服务而收取的报酬

## 15. 什么是退出方式（跟随）？

## 16. 什么是认购中、已获配？
基金在新发行的时候才说是认购中，

基金要买很多股票，不同的行业都要买，每类股票都会买一部分，获赔就是这个行业所既定的比例。

## 17. 固收理财和IPO锚定有什么区别？
固收理财产品是一种理财术语，固定收益率产品投资于存款、债券等债券类资产的比例不低于80%。目的是回避利率和汇率风险，是增加驾驭经济不稳定性和控制风险的手段。主要那是回避利率和汇率风险，增加驾驭经济不稳定性和控制风险的手段，满足融资者需求

    IPO锚定
    
    在IPO中指的是在路演和薄记开始前即明确表达了投资意向、并在路演和薄记第一天就下单的订单。

## 18. 什么是退出回款？
基金没有申购成功，把钱退回到原来的电子账户中

## 19. 什么叫做持仓？【指保留手中的股票、基金、国债等不抛出】
在实物交割或者现金交割到期之前，投资者可以根据市场行情和个人医院，自愿地决定买入和卖出期货合约。而投资者没有作交割月份和数量相等的逆向操作，持有期货合约，则称之为持仓。
（在期货交易中，无论是买还是卖，凡是新建头寸都叫开仓。交易者建仓之后手中就持有头寸（是指银行、钱庄等所拥有的款项），这就叫持仓）

## 20. 什么叫做清仓？
清仓就是把指自己已经买进和持有的股票全部卖出

## 21. 什么是模拟组合？
是经过管理人精心配置的基金。体现了管理人的投资思路，帮助发现新的投资机会。

## 22. 什么是印花税？
印花税是对经济活动和经济交往中订立、领受具有法律效力的凭证的行为所征收的一种税，因采用在应税凭证上粘贴印花税票作为完税的标志而的命。它可以由纳税人按规定应税的比例和定额，自行购买并粘贴印花税票，或委托代征，税务机关经由发放或者办理应税拼争的的单位作为征收。

基金财务知识

jenkins其实自带分布式特性，是Master/Slave模型。在Master上分配任务，然后在slave或者Master完成。这个特性带来两个好处：
* 能够有效分担主节点的压力，加速构建速度
* 能够指定特定的任务在特定的主机上进行



# 使用场景
1. 如果项目需要定期集成，同时每次集成都需要较长时间。如果都运行在master服务器上，会消耗过多资源，这时就需要在建立多台设备，并配置为slave机器来为master提供负载服务
2. 需要不同的环境集成。如一个项目，包含Web端，包含Android端，包含IOS端，不同的测试需要的环境都不同，此时可以为每个环境配置一个slave测试。
3. 一个slave是一台为主的jenkins机器建立一个负载build项目的电脑，一旦建立这个分布式任务是完全自动化的。每个slave运行一个单独的程序，不需要再一个slave安装全部的jenkins


Master的职责：
负责调度任务和发送请求
Slave的职责：
多个Salve可以并发的执行并构建任务，或者用于分布式的自动化测试，当自动化测试代码非常多或者而是需要在多个浏览器上并行的时候，可以把测试代码分到不同节点上运行，从而加速自动化测试的运行。

流程：
1. Master——Slave（管理节点，分配任务）
2. Salve(向master注册，反馈状态：空闲/忙碌,反馈任务进度，反馈任务结果)


Jenkins分布式环境搭建步骤如下：
1. master节点上安装和配置jenkins
2. master节点上新增Salve节点配置，生成master-slave通讯文件SlaveAgent
3. Slave节点上运行SlaveAgent，通过SlaveAgent实现和Master节点的通讯
4. Master节点上管理Jenkins项目，指定Salve调度策略，实现Slave节点的任务分配和结果搜集
5. Master节点上安装和配置Jenkins

jenkins分布式构建

# 部署上线
> 什么是部署？
部署指的是把程序托管到拥有公网ip的远程服务器(计算机)上，这样程序可才可以被互联网上的所有人通过IP或映射到IP的域名访问到



# 传统部署VS云部署VS静态部署
* 传统部署
    1. 类似于毛胚房，需要自己动手设置所有环境
    2. 通常会通过虚拟主机服务提供商来租用虚拟主机，这些服务被成为IaaS（设施即服务）。主流的有Amazon Ec2、阿里云云的ECS
    3. 传统部署比较灵活，一切都由你自己来掌控，不过同时需要耗费较多的经历去进行环境搭设和维护，需要运维人员来维护。
    4. 如果不想把时间都花费到运维上，只想尽快让你的程序部署上线，可以考虑使用云部署
* 云部署
    1. 精装修的公寓，程序只需要接通电源就可以运行
    2. 云部署即Pass（平台即服务）。简单来说，云部署服务提供了一个完善的平台，提供了所有底层基础设施，我们只需要推送程序代码即可。
    3. 使用云部署，可以省去配置服务器、设置数据库、配置网络服务器以及设置防火墙等步骤。使用简单的方式即可集成第三方工具、添加数据库、设置邮件服务等，使用起来非常灵活
    4. 例如paas的有HeroKu PythonAnywhere，Webfaction,Goolge App Engine等。普通人推荐HeroKu
    
* 静态部署
    1. 静态部署是先借助工具将程序静态化处理，比如使用扩展Frozen-Flask,静态处理就是把程序中的所有动态页面全部转换成对应的HTML文件，分目录放置。
    2. 静态处理后的程序部署成本非常低，而且有大量免费的静态部署服务，比如Github Pages\Netlify等
    3. 一般适用于不需要接受用户输入、不产生动态输出的程序，比如个人博客
    


# 1. 基本部署流程
如果你将程序代码托管在在线代码托管平台比如Github\BitBucket\Gitlab等，那么使用Git部署程序的过程非常简单，和在你自己的电脑上运行程序的基本相同，大致流程如下：
    
    * 在本地执行测试
    * 将文件添加到Git仓库并提交（git add & git commit）
    * 在本地将代码推送到代码托管平台(git push)
    *　在远程主机上从代码通过平台复制程序仓库　git clone
    * 创建虚拟环境并安装依赖
    * 创建实例文件夹，添加部署特定的配置文件或是创建.env文件存储环境变量并导入。
    * 初始化程序和数据库，创建迁移环境
    * 使用Web服务器运行程序

##　1.1 更新程序步骤
    
    * 在本地执行测试
    * 将文件添加到Git仓库并提交  git add & git commit
    * 在本地将代码推送到代码托管平台 git push
    * 在远程文件上从代码托管平台拉去程序仓库 git pull
    * 如果有依赖变动，或是数据库表结构变动，那么执行依赖安装和数据库迁移操作
    * 重启Web服务器

# 2. 部署前的准备
##　2.1 更新程序配置
* .env文件。不同的环境需要不同的配置，将某些包含敏感信息的配置变量优先从环境变量获取，比如数据库URL、Email服务器配置信息等。将这些关键信息填写到.env文件中。记得将文件放到.gitignore中
* SECRET_KEY 。我们需要要为保存程序密钥的SECRET_KEY配置变量生成一个随机字符，更换开发时填入的占位字符。
  ```python
  # 随机密钥的生成方式有很多。比如，os模块的urandom()方法可以用来生成随机密码
  import os
  os.urandom((12))
  # 如果使用python3.6，可以使用secrets模块提供的token_bytes()、token_hex()、token_urlsafe()方法
  import secrets
  token_urlsafe(16)
  # 或者使用uuid
  ```
* 如果需要执行flask相关的命令，需要配置.flaskenv的文件



在PythonAnywhere部署程序时，因为PythonAnywhere使用的数据库服务会在5分钟断开连接，需要将flask_sqlalchemy提供SQLALCHEMY_POOL_RECYCLE配置变量的值设为300一下，用来设置数据库连接池的回收时间，比如:
```shell
SQLALCHEMY_POOL_RECYCLE=280
```
# 3. 创建生产环境专用的程序
##　3.1 设置迁移工具
详情查看[5数据库](./5数据库.md)

##　3.2 程序日志
1. 将日志写入到文件中
```python
import logging
from logging.handlers import RotatingFileHandler
def create_app(config_name=None):
  register_logger(app)
  
def register_logger():
    app.logger.setLevel(loggging.INFO)
    formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
    file_handler = RotatingFileHandler('logs/bluelog.log',maxBytes=10*1024*1024,backupCount=10)
    file_handler.setFormatter(formatter)
    file_handler.setLevel(logging.INFO)

    if not app.debug:
        app.logger.addHandler()
```
> 代码解释：
> * 为了让日志记录器记录INFO等级的日志时间，我们首先将app.logger的等级设为INFO。
> * 然后创建一个logging.Formatter对象设置日志的输出格式。
> * 为避免日积月累产生一个巨大的日志文件，我们使用RotatingFileHandler类（从logging.handlers模块导入）创建一个轮转文件类型的日志处理器，实例化这个类传入日志文件目标路径、最大文件尺寸和备份数量。
> * 当日志文件的大小超过实例化传入的maxBytes参数设定的值时（单位为字节byte，我们这里设为10MB），它会循环覆盖之前的记录
> * 将backupCount参数设为10次，会依次创建10个日志文件，10个文件全部存满10MB后会开始覆盖之前的文件；
> * TimeRotatingFileHandler类，它会根据设定的时间间隔（通过实例化传入参数设定）来定期覆盖日志数据


### 日志不需要传入到Git仓库中的方法？
* 在项目根目录下创建一个logs文件夹
* 在logs目录下文件一个.gitkeep文件，并在.gitignore中写入一个*.log规则，这会确保将logs目录添加到Git仓库，但是忽略所有以.log结尾的日志文件


2. 云部署平台的日志
云部署平台会从stdout（标准输出）和stderr(标准错误输出)收集日志，如果要吧程序部署到云平台上，需要创建一个StreamHanler类型的日志处理器来替代上面的RotatingFileHandler处理器
   
3. 通过邮件发送关键日志
在生产环境重，低等级的信息可以记录到日志文件重，而关键的信息（比如Error等级以上）则需要通过邮件发送给管理员，以便及时休闲服问题
   
为了在日志信息重插入出发这个日志事件的请求信息，我们创建一个自定义的RequestFormatter类，它继承自logging.Formatter类，添加了几个自定义字段来插入请求信息。

```python
import requests
import logging


def register_logger():
  class RequestFormatter(logging.Formatter):
    def format(self, record):
        record.url = requests.url
        record.remote_addr = request.remote_addr
        return super(RequestFormatter,self).format(record)
  request_formatter = RequestFormatter(
    '[%(asctime)s] %(remote_addr)s requested %(url)s \n %(levelname)s in %(module)s: %(message)s' 
  )
```
使用SMTPHandler类可以创建一个SMTP处理器，传入的参数太多从相应的Flask-Mail配置变量获取。我们将这个邮件日志处理器的等级设为logging.ERROR,当发生Error等级及以上的日志事件时会将日志通过邮件发送给管理员
```python
import os
import logging
from logging.handlers import SMTPHandler

def register_logger():
    mail_handler = SMTPHandler(
      mailhost=os.getenv('MAIL_SERVER'),
      fromaddr=os.getenv('MAIL_USERNAME'),
      toaddrs=os.getenv('BLUELOG_ADMIN_EMAIL'),
      subject='Application Error',
      credentials=(os.getenv('MAIL_USERNAME'),os.getenv('MAIL_PASSWORD'))
    )
    mail_handler.setLevel(logging.ERROR)
    mail_handler.setFormatter(request_formatter)

    if not app.debug:
        app.logger.addHandler(mail_handler)
```

除了传统的日志记录，我们还可以使用第三方错误追踪工具来处理程序中的错误。流行的选择是Sentry，当在程序中集成Sentry后，它可以在程序出现异常时通过我们设置的各种方式发送提醒（除了邮件，还可以集成Slack、Whatsapp、IRC等第三方工具）

更重要的是，我们可以在的控制面板中查看关于这个异常的相关代码、上下文变量的值、函数调用堆栈、以及异常触发的次数、涉及的客户端信息等一系列数据，这能够帮助我们及时找出问题的根源并解决问题。

[Sentry更多学习连接](https://juejin.cn/post/6844904143090352135)

[Sentry掘金博客连接](https://zhuanlan.zhihu.com/p/210765546)

# 4. 部署到Linux服务器
准备：
* 远程主机
* 购买一个域名
* 域名解析

## 4.1 登录远程主机，安装基本库和工具
## 4.2 安全防护措施
## 4.3 推送代码并初始化程序环境
## 4.4 使用gunicorn运行程序
## 4.5 使用nginx提供反向代理
## 4.6 使用Supervisor管理进程
我们直接通过命令来运行gunicorn,这并不十分可靠。我们需要一个工具来自动在后台运行它，同时监控它的运行状况，并在系统出错或是重启时自动重启程序。
在/etc/supervisor.d/创建wiki.ini **视个人情况，创建配置文件**
```shell
[program:eric_web]
command=pipenv run gunicorn -w 2 -b 127.0.0.1:5001 wsgi:app --preload  # 需要执行的命令
directory=/root/program/EricWeb #命令执行的目录
environment =PYTHONPATH="$PYTHONPATH:/root/.local/share/virtualenvs/EricWeb-qMyTWs2e/bin" #环境变量
user=root #用户
stopsignal=INT
autostart=true #是否自启动
autorestart=true #是否自动重启
startsecs=60 #自动重启时间间隔（s）
stderr_logfile=/var/log/eric_web/webs.err.log #错误日志文件
stdout_logfile=/var/log/eric_web/webs.out.log #输出日志文件

```
重启
```shell
supervisorctl reload
```
除了命令行工具supervisorctl,Supervisor还提供了Web客户端，你可以通过在/etc/supervisor/supervisord.conf中写入下面的配置来开启：
````shell
[inet_http_server]         ; inet (TCP) server disabled by default
port=*:9001        ; (ip_address:port specifier, *:port for all iface)
username=yourname              ; (default is no username (open server))
password=yourpassword
````
> ; 后边的语法代表注释

# 5. 更新部署后的程序
不过，尽量避免这种方式，先在测试环境测试ok了之后，再提交到生产环境中
1. 在本地更新代码
2. 通过生成虚拟数据再浏览器中手动调试
3. 调试满意后执行一系列测试
4. 测试通过后将代码推送到代码托管平台，触发持续集成服务器进行测试
5. 登录远程主机，使用git pull命令拉取更新
6. 执行必要的操作，比如更新数据库结构，安装新的依赖等。
7. 重新启动gunicorn


# 6. 在PythonAnywhere和HeroKu部署
都是国外的，而且基于Amazon来实现的，有一定的延迟，不适合国内生产。