README.md 3.5 KB
Newer Older
G
gongweibao 已提交
1 2
# FileManager设计文档
## 目标
G
gongweibao 已提交
3 4
在本文档中,我们设计说明了名为FileManager系统,方便用户管理存放到PaddlePaddle Cloud上的文件。   
主要功能包括:
G
gongweibao 已提交
5

G
gongweibao 已提交
6
- 提供常用的命令行管理命令管理文件和目录
G
gongweibao 已提交
7
	- 支持的命令在[Here](./pfs/pfs.md)
G
gongweibao 已提交
8
- 支持大文件的断点上传、下载  
G
gongweibao 已提交
9

G
gongweibao 已提交
10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29
## 名词解释
- PFS:是Paddlepaddle cloud File System的简称,是对用户文件存储空间的抽象,与之相对的是Local File System。目前我们用CephFS来搭建。
- [CephFS](http://docs.ceph.com/docs/master/cephfs/):一个POSIX兼容的文件系统。
- Chunk:逻辑划上文件分块的单位。
- [Ingress](https://kubernetes.io/docs/concepts/services-networking/ingress/):提供七层协议的反向代理、基于粘性会话的负载均衡。
- CA:certificate authority<sup>[tls](#tls)</sup>
- CRT:CA signed certificate<sup>[tls](#tls)</sup>
- Key:用户私钥<sup>[tls](#tls)</sup>

## 模块

### 架构图
<image src=./src/filemanager.png width=900>

### PFSClient
- 功能: 详细的内容看[Here](./pfs/pfs.md)
	- 提供用户管理文件的命令
	- 用Golang写,可以跨平台执行

- 双向验证   
G
gongweibao 已提交
30
	PFSClient需要和Ingress之间做双向验证<sup>[tls](#tls)</sup>,所以用户需要首先在`cloud.paddlepaddle.org`上注册一下,申请用户空间,并且把系统生成的Key、CRT、CA下载到本地,然后才能使用PFSClient。
G
gongweibao 已提交
31
	
G
gongweibao 已提交
32
### Ingress
G
gongweibao 已提交
33 34 35 36 37
- 功能:  
	提供七层协议的反向代理、基于粘性会话的负载均衡功能。
	
- 透传用户身份的办法  
	Ingress需要把PFSClient的身份头传给FileServer,配置的方法参考[Here](http://www.integralist.co.uk/posts/clientcertauth.html#3)
G
gongweibao 已提交
38 39


G
gongweibao 已提交
40 41
### FileServer
FileServer是一个用GoRPC写的HTTPServer,提供[RESTful API](./RESTAPI.md)接口,接收处理PFSClient端的文件管理请求,并且把结果返回PFSClient端。
G
gongweibao 已提交
42

G
gongweibao 已提交
43
## 文件传输优化
G
gongweibao 已提交
44

G
gongweibao 已提交
45
### 分块文件传输
G
gongweibao 已提交
46
用户文件可能是比较大的,上传到Cloud或者下载到本地的时间可能比较长,而且在传输的过程中也可能出现网络不稳定的情况。为了应对以上的问题,我们提出了Chunk的概念,一个Chunk由所在的文件偏移、数据、数据长度及校验值组成。文件数据内容的上传和下载都是都过Chunk的操作来实现的。由于Chunk比较小(默认256K),完成一个传输动作完成的时间也比较短,不容易出错。PFSClient在传输完毕最后一个Chunk的时候检查destination文件的MD5值是否和source文件一致。
G
gongweibao 已提交
47

G
gongweibao 已提交
48
一个典型的Chunk如下所示:
G
gongweibao 已提交
49

G
gongweibao 已提交
50 51
```
type Chunk struct {
G
gongweibao 已提交
52 53
	fileOffset int64
	checksum uint32
G
gongweibao 已提交
54 55 56 57
	len     uint32
	data    []byte
}
```  
G
gongweibao 已提交
58

G
gongweibao 已提交
59 60
### 生成sparse文件
当destination文件不存在或者大小和source文件不一致时,可以用[Fallocate](https://golang.org/pkg/syscall/#Fallocate)生成sparse文件,然后就可以并发写入多个Chunk。
G
gongweibao 已提交
61

G
gongweibao 已提交
62 63
### 覆盖不一致的部分
文件传输的的关键在于需要PFSClient端对比source和destination的文件Chunks的checksum是否保持一致,不一致的由PFSClient下载或者传输Chunk完成。这样已经传输成功的部分就不用重新传输了。
G
gongweibao 已提交
64

G
gongweibao 已提交
65 66
## 框架生成
[swagger-api](https://github.com/swagger-api/swagger-codegen)生成Client和FileServer的框架部分,以便我们可以把更多的精力放到逻辑本身上。
G
gongweibao 已提交
67 68

## 参考文档
G
gongweibao 已提交
69
- <a name=tls></a>[TLS complete guide](https://github.com/k8sp/tls/blob/master/tls.md)
G
gongweibao 已提交
70 71
- [aws.s3](http://docs.aws.amazon.com/cli/latest/reference/s3/)
- [linux man document](https://linux.die.net/man/)