|
为什么需要BlueStore Ceph作为软件定义存储(SDS)解决方案,其首要目标是保障存储数据的安全。为了达到数据安全的目的,Ceph使用了WAL的方式(Write-Ahead-Log),这就是我们日常最熟悉的journal. 但是写前记录日志这种技术有一个主要缺陷就是它把你的硬盘性能降低到原来的二分之一(仅当日志和OSD数据共享同一个硬盘时),因为filestore在写数据前需要先写journal,所以有一倍的写放大。 filestore设计初衷就是就是为了充分发挥普通机械盘的性能,没有对SSD进行优化考虑。但随着SSD全面普及(主要性价比越来越实惠,也是新技术不断推陈出新的结果),Ceph应用在SSD之上案例越来越多,对于性能的需求是更加迫切。基于以上现实,社区推出了Bluestore的存储引擎,剔除journal方案,缩减写放大,优化SSD写入,同时数据直写裸盘。 BlueStore架构整体架构 内部组件- RocksDB: 存储预写式日志、数据对象元数据、Ceph的omap数据信息、以及分配器的元数据(分配器负责决定真正的数据应在什么地方存储)
- BlueRocksEnv: 与RocksDB交互的接口
- BlueFS: 迷你的文件系统(相对于xfs,ext2/3/4系列而言),解决元数据、文件空间及磁盘空间的分配和管理。因为rocksdb一般是直接存储在POSIX兼容的文件系统(如ext3/xfs等)之上,但BlueStore引擎是直接面向裸盘管理,没有直接兼容POSIX的文件接口。但幸运的是,rocksdb的开发者充分考虑了适配性,只要实现了rocksdb::Env 接口,就能持久化rocksdb的数据存储(包含RocksDB日志和sst文件)。BlueStore就是为此而设计开发的,它只包含了最小的功能,用来承接rocksdb。在osd启动的时候,它会被"mount"起来,并完全载入内存
- Allocator: 用来从空闲空间分配block(block是可分配的最小单位)
+ S* x$ F* J- I
说明:
( l. S6 F( D0 f; \1.对象数据存储部分即osd指定的data设备(可以是裸盘分区,或者lvm卷,下同)" @) Q0 Q! s {- \
2.RocksDB日志即osd指定的wal设备3 `9 D( u" `9 J9 f2 m, n5 r
3.RocksDB数据部分即osd指定的db设备, P- ]0 f* O1 `
4.以上设备可以共用同一物理盘设备,也可以分开在不同的物理设备,这充分体现了ceph的灵活性
以上只是本人粗糙的理解(未必完全正确或者跟实际有出入),希望有大师出来指点一二。 部署实战基础环境1- E; _0 x) E7 @! ?' u3 ]7 M
2) M4 {3 k: M- T# F& I7 X) _
3
( l/ ?+ C# f4 E- I1 }" {* r | 3 ]9 X/ m: _' ^! u8 c5 O: T
[root@compute ~]# ceph -v0 j/ {, e! S) G4 J
ceph version 13.2.0 (79a10589f1f80dfe21e8f9794365ed98143071c4) mimic (stable)
& J5 j6 W# z4 k9 L1 J- Y |
在创建osd之前,集群已经初始化完毕(即已经有Mon节点)。先熟悉下ceph-volume,可以看到当前支持lvm和simple两类子命令集。lvm用来创建osd,simple则是管理已经创建的osd。 1
- a0 e% x9 n6 x) C3 K) T, L4 N8 Z7 |/ ^24 Y. d* V% T9 I& }% x! P0 \3 ~
3
9 K& B$ {, K' Z45 f! h$ z S5 E9 L% ]+ i. Q- @. i
5
2 |- m$ B3 v x/ s7 V v/ f' m6
! `7 P: D5 N) A" u- ]1 q( x4 @74 X' j& O5 z8 S( f: ^ ^2 @" i, U2 t! b
| ceph-volume -h; O7 }" ^' _8 x
% { N& I1 j3 s9 u; Q: ^2 {9 c2 X1 \" H... <中间省略>
. @: t, M( h: C+ u3 g; jAvailable subcommands:7 T% X2 n& v. Q+ o' f; f3 G
& A- P( m# o; i
lvm Use LVM and LVM-based technologies like dmcache to deploy OSDs! j- l n# \' ]* A& @7 _9 s5 K# z
simple Manage already deployed OSDs with ceph-volume
! D) X: E( V2 `% ~" | |
预先创建好需要的lvm卷,如果没有独立的盘来单独存放wal和db,不推荐再在设备上面创建lvm卷分配给db和wal。默认只需要指定数据路径(–data)即可。Bluestore会自动管理所有的空间(包括data、db、wal)。 注意& b) U; d. K. y4 j9 X" H6 X- u; B
如果有独立的盘来存放db,官方推荐db的空间不应小于数据空间的4%,以1T的数据空间为例,db的大小不应该小于40G.官方连接 创建lvm卷以下创建的lvm卷只做演示用,data、db、wal分别创建独立的卷 1
' }' \# u4 [# N! H1 W5 z2
7 O* x. B0 x1 D38 ^6 C! h/ f7 V$ C: Q
4& I# U. e0 | ^( v. X) c0 h( P
5
5 I: m1 g9 t) N; o1 p6
H7 j% `0 {8 v: l5 p- E2 @7# o1 P! e2 B/ _
8
% i: G! F9 d( d0 {# i; z! i9( i; N6 ?& \: X0 S" [7 x
10
+ W4 L7 } o2 a; L2 l5 H2 R; k116 B% g% R1 f1 X$ p2 H! C
| [root@compute osd]# vgcreate osd.3 /dev/sde
7 s6 [5 d2 s, z$ K Volume group "osd.3" successfully created
7 H1 M5 b$ W6 w3 x! @5 v A9 V9 t2 H) G" {0 D H
[root@compute osd]# lvcreate -L 1G -n osd.3.db osd.3+ [- R( t) ]9 ]* h
Logical volume "osd.3.db" created.$ W. i1 n2 \; K2 W5 t$ O
! s- D, b9 W. C
[root@compute osd]# lvcreate -L 1G -n osd.3.wal osd.3
, k1 ?$ }) J, U1 T: o Logical volume "osd.3.wal" created.
0 s+ i8 n, C0 f) M! r# M& E" {2 |; \8 Q* n, o- T N
[root@compute osd]# lvcreate -l 100%FREE -n osd.3.data osd.3* S" Z& I. ]4 q0 T
Logical volume "osd.3.data" created.1 ^! X9 J9 `" V
| 创建osdimage_1cn618mlp1eskvqdeov12o1vgj19.png-232.8kB 从上面的截图其实可以把整个create流程分解为prepare和activate阶段,下面就开始庖丁解牛。 prepare 阶段- 收集keyring
1
( P8 s" z5 E3 `; T! t, k' J | Running command: /bin/ceph-authtool --gen-print-key
Z+ X* I3 c! Z |
- 创建新的osd id
19 \* c/ ^! \/ o3 C0 Q
| Running command: /bin/ceph --cluster ceph --name client.bootstrap-osd --keyring /var/lib/ceph/bootstrap-osd/ceph.keyring -i - osd new 9501a491-625f-4c2c-bf8e-a1a27cc0e6e5
0 C! b9 |0 q O1 d |
- 挂载tmpfs目录,这不同于旧版本使用本地文件系统。BlueStore把这些依赖的文件信息都写入到了裸盘里(在osd启动之前,会重新生成)
1) [, G+ K/ v$ I6 V/ g/ s1 h6 V1 @, K
| Running command: /bin/mount -t tmpfs tmpfs
, }: `% g* W& |4 W6 ~ |
- data对应设备创建软链
1
8 _0 }4 Y- T9 X, L o) D | Running command: /bin/ln -s /dev/osd.3/osd.3.data /var/lib/ceph/osd/ceph-3/block. o, P. c( _5 w6 h6 l: B9 O
|
- 获取当前集群的monmap
1
6 y `2 ~5 M( T7 \ | Running command: /bin/ceph --cluster ceph --name client.bootstrap-osd --keyring /var/lib/ceph/bootstrap-osd/ceph.keyring mon getmap -o /var/lib/ceph/osd/ceph-3/activate.monmap4 G5 w3 W) ^1 j6 \# `* w
|
- 写入keyring文件并在集群注册
1: X, A2 g- t `9 }3 C; x
| Running command: /bin/ceph-authtool /var/lib/ceph/osd/ceph-3/keyring --create-keyring --name osd.3 --add-key AQCy/Zdb4rTZIRAApGGe5QENqb/UPUHVRzI5Dw==& A, S- h2 D5 }) t4 ?4 a
|
- keyring文件和工作目录以及设备的权限设置
1& R( E9 \8 a# ^6 J6 J0 w4 V' ]5 w
2+ V3 l: |9 f: D; n
3) f/ \5 x: V& u( B( d! z5 y
4' v+ j$ G, r1 C& I
| Running command: /bin/chown -R ceph:ceph /var/lib/ceph/osd/ceph-3/keyring# ^+ X" g' u# s h3 _# |1 F
Running command: /bin/chown -R ceph:ceph /var/lib/ceph/osd/ceph-3/
( O* \: d9 M% g- ~9 mRunning command: /bin/chown -R ceph:ceph /dev/dm-16
7 {4 N3 X' m; j% g c& {0 q: |3 GRunning command: /bin/chown -R ceph:ceph /dev/dm-15. E8 S$ I% O* {* ^: N: Y
|
- mkfs初始化bluestore
12 n' S3 H8 n/ f" Z& V; @0 S% H
| Running command: /bin/ceph-osd --cluster ceph --osd-objectstore bluestore --mkfs -i 3 --monmap /var/lib/ceph/osd/ceph-3/activate.monmap --keyfile - --bluestore-block-wal-path /dev/osd.3/osd.3.wal --bluestore-block-db-path /dev/osd.3/osd.3.db --osd-data /var/lib/ceph/osd/ceph-3/ --osd-uuid 9501a491-625f-4c2c-bf8e-a1a27cc0e6e5 --setuser ceph --setgroup ceph5 M- O/ K& A$ D2 v& z
| 以上就是prepare的过程中涉及到的相关操作。- o- F5 W+ A, i# D j
acitivate 阶段小结:7 T% S' a& o7 l6 @* t
以上分解的osd创建步骤,为后续使用ansible来自动化部署Ceph集群至关重要。后续打算写个简单部署ceph的playbook,在此先mark下。 启动分析BlueStore的OSD启动不同于老版本基于udev规则触发ceph-disk相关命令来启动,它依赖于ceph-volume相关服务与命令。 ceph-volume 系统服务上面可以看到,在创建osd的过程中有注册一个系统服务ceph-volume@lvm-3-9501a491-625f-4c2c-bf8e-a1a27cc0e6e5, 12 q; o8 M2 n' L5 j
2
) f8 D3 X- c2 \3
& A5 f/ t. C& h1 a4 l V; w4% ]0 ]" A7 J8 y) |3 Q7 {8 i
5
9 y' M; S- _* L5 ?0 ?+ V1 }6/ r. b( Y: r6 W% M/ {
7
1 x: U0 @7 ]* D+ z: h6 R82 k# z% W7 l$ V: ^+ V, i9 {0 q
9
3 P4 u7 K5 P, P: u100 U; k, E* S" t0 @
11, t$ R7 D( Z& m& u8 U
12' K. o9 X- S9 _. `7 V9 m
13
. p; w4 k; z, n+ s142 q6 S) U$ v( _* N( J/ t- c( B8 A
15" g5 s! m3 T7 R/ r
| #cat /usr/lib/systemd/system/ceph-volume@.service
1 W# m* q% n- _1 x5 S4 Q[Unit]8 R9 ^3 u5 Z7 l( O" b$ u9 d
Description=Ceph Volume activation: %i
" q' U& x) s- x, G7 z& V; P" @) AAfter=local-fs.target& L# u) a9 j1 A9 i: N% Q/ W
Wants=local-fs.target- E. R7 l! _2 s3 F! H* e
- L( k1 i) q7 w% M. G[Service]
' E! V0 |% q( r" h! w# f, UType=oneshot% R- H4 d- x& Y" S1 m
KillMode=none- [* O I! S, _/ ~
Environment=CEPH_VOLUME_TIMEOUT=10000: Z' s% h5 s# b3 K/ ~+ H0 N& f7 A
ExecStart=/bin/sh -c 'timeout $CEPH_VOLUME_TIMEOUT /usr/sbin/ceph-volume-systemd %i'
[5 w9 ~% M& j4 t- M xTimeoutSec=0
0 {. o! J! `% q0 `
8 y; m, v# `" A- w; \[Install]
: G) h9 Q6 f! k* Y) p) ~3 Y* }) @WantedBy=multi-user.target
, n- x9 [% E% C( s+ ? Y |
这个系统服务是在local-fs之后就执行了,优先级别是比较高的。这个服务传入的参数是lvm-3-9501a491-625f-4c2c-bf8e-a1a27cc0e6e5。其时可以分解为lvm、3、9501a491-625f-4c2c-bf8e-a1a27cc0e6e5.见明知意,分别是是lvm标签,osd的id,osd的uuid。4 p" H) Y% q! D9 c% N. _5 C) Y
系统服务只有一个简单的脚本。 14 I# G1 r% {" g) q: G& R
2
* i+ }2 G* b6 `( l0 [! S$ S3& A4 f2 r! G/ [; r& j
4
7 U! _7 a, X3 C- ~) s! T- V56 \( l1 `8 j& [: |; `7 D
61 E( }5 r* Z8 e) Y
71 w" }$ G% k, H
| # cat /usr/sbin/ceph-volume-systemd$ N0 X' a1 a1 |+ E& G( m* b
#!/usr/bin/python2.7
4 I! \# e% e& N/ @ Z4 C) T, P6 z
# B4 U1 d( F: wfrom ceph_volume.systemd import main7 q) x% Y! ^; L( |, x& Z" m
- T! d6 b2 x; |( `% {. G/ ~
if __name__ == '__main__':
" k, T* {3 M* f, g: c7 W main.main()
5 o9 {4 W$ U k4 L |
从上面看,已经开始进入ceph-volume项目了。( N& B; l, b: B
项目路径是ceph/src/ceph-volume 1
% {( q3 x" R2 V24 h/ b$ a- W/ @ V7 f- s% i* h
3* O4 R! P5 S9 U, }# b! w1 W
4$ f* U/ e& ]0 K8 C) H7 c4 ]& \* {
5. e3 r- }7 S A0 [: R: p% u. h
6; e2 X* n, r9 v: n( p* ?5 T. D
74 ~$ m' y& \3 t, T4 r
8
1 Q* g3 `( T" T: O: h0 T90 A) k( u, T5 X0 j! a* x5 k0 S Y3 t
10) p% {' ^$ ^% B- N2 t+ @ h3 q
11* ~! Z6 }6 i4 ~* S
12
" g& F% {/ r G3 i; D132 E: @% ^; Q8 b% e
14
: b' W7 V `- t. |9 B# |15
. s% Z M! X" ^& ?- P) `$ S16; U$ n: q0 R- M: H
17& |9 k7 R1 M7 ]4 X5 M
18" m3 c p0 \" O; x' b
19 o7 ^9 j' U' c! ^
20' h$ L0 @, D: A" ?) F
216 P8 d' H7 k, c0 s9 A! e
| ## ceph/src/ceph-volume/systemd/main7 O9 ]) ^& l! E( L* |2 F
def main(args=None):% W7 h. Y* t6 K0 L
"""
' I8 |1 r) P" q2 ]7 Q3 P, N6 A0 N ... < 中间省略>
1 ?' j+ y0 y2 X; `5 G/ ^ ## 转换为ceph-volume lvm 命令 继续执行 ##
* [- n# d# f5 S" e ceph-volume lvm trigger 0-8715BEB4-15C5-49DE-BA6F-401086EC7B41
! ^1 @- M6 V0 ~4 l$ I+ b2 `& r; d3 s* c& [* x9 z6 @& }0 B
"""% h' o1 i: X8 H7 r
log.setup(name='ceph-volume-systemd.log', log_path='/var/log/ceph/ceph-volume-systemd.log')
/ n- b8 X5 D+ e7 w- } logger = logging.getLogger('systemd')$ H: o/ |2 v0 D- [
... < 中间省略> + D V/ E+ W, N5 ~* |
## 参数解析7 ~1 h2 r( W% c
sub_command = parse_subcommand(suffix)
0 K+ z4 S$ |* W r0 X extra_data = parse_extra_data(suffix)' q N% m' ?2 b/ }6 c& M( \
... < 中间省略> 4 i$ H) f9 p% Z" M: |, @- c" J/ f
## 构造成为['ceph-volume','lvm','trigger','id-uuid']的格式
( |2 g2 E8 H" D4 B/ V5 K; g command = ['ceph-volume', sub_command, 'trigger', extra_data]. m4 ?) H. _- e2 _# p( ?
tries = os.environ.get('CEPH_VOLUME_SYSTEMD_TRIES', 30)
; K6 g6 j! ~1 I/ n6 b interval = os.environ.get('CEPH_VOLUME_SYSTEMD_INTERVAL', 5)1 U3 n; Q) q* \* z% N
... < 中间省略>
, U( x9 U) b) O) q9 ?7 M. U process.run(command, terminal_logging=False) ##下一步执行入口##0 M8 c8 m3 a# Y2 o3 ~2 \* N% d
|
这里只是对传入的参数进行处理,最后调用ceph-volume lvm trigger ceph-volume lvm trigger 处理1
0 e4 h& r" J) T2# Q3 C. ^% E) M u; y% u
3- {3 c1 c7 ^/ l$ c! \
4
' x! j+ N/ U4 c2 ]" |5
2 F2 m3 N% o# g4 O5 {6 t' @6) h9 |' y" x1 R' e
7
; A- t3 b' `7 c( \% ]. D | #cat /usr/sbin/ceph-volume
1 v; H4 L& e5 n0 B1 _: h) W! X#!/usr/bin/python2.7- b0 r- s8 G4 s, J
# Q8 A5 Y$ z6 Q6 q# Y" Z9 Y
from ceph_volume import main
8 F2 h- \7 i! i. h* w4 ?9 U1 b
% _: \' {2 }$ m6 Q0 @; fif __name__ == '__main__':: d7 F+ ]- l- _. ~ d- \/ I
main.Volume()
1 T2 I9 r, N6 l+ F |
下面进入ceph/src/ceph-volume/main,找到入口函数main() 1 R5 u1 ~/ g& j Y5 z
2
6 T4 c2 i6 k/ k2 J! Q3
. I1 [" t5 s: a7 [7 b4
' t x% ^8 F) ]8 ]; I9 ]; q+ k5* {' A6 j0 K, p- {
6
5 ?' K/ O8 E6 j/ h: h4 [( q7
/ C6 q3 Q" N; b2 R: i! I8 N8
2 s2 r" Z" c6 s$ `5 l9
# w9 f) V3 c" S3 m" \10 K; l& z2 V& B8 K9 L% }0 A* b& }4 p" {
| def main(self, argv):
& p% }9 }7 M) p # these need to be available for the help, which gets parsed super4 T! X, G! \8 c0 B
# early, k) ^8 h5 r8 h& t2 M
## 一些预备处理,比如日志,ceph配置路径等% U$ d( h, o ^$ ? \
self.load_ceph_conf_path(), b; H, _: M$ l; v# Y* Y& i
self.load_log_path()
* ]7 s' z; y. I self.enable_plugins()
7 E2 {5 A- W3 B% p+ r3 M main_args, subcommand_args = self._get_split_args()0 `5 P) |% c; U
...<中间省略># [+ W0 `) v0 X' m9 d9 g
terminal.dispatch(self.mapper, subcommand_args)& l; o" M3 v2 f1 j, c- W7 w
|
最终进入的是terminal.dispatch,核心是传入的参数。; h$ s6 { q- ~: X# r$ {
以下是pdb的结果,其实这是一个工厂模式的设计实现,根据subcommand_args里类型,创建对应的实例,通过实例方法实现功能处理。
- }3 z9 T1 g! r" b9 zimage_1cn6k8a3e1f754eu15armjhcgj9.png-25.6kB 1& _5 j; B5 ~4 D! V' S
2
3 M6 j! C0 k* x4 F' {, x( ~, e3$ P4 Z4 J; D* S
49 I$ N9 E) z8 @2 ~ G
5
% ^" t! Q9 @1 s9 l8 X4 o67 j6 O& d& r% s& |9 P. p, A
7
$ a# R. s! c4 J81 y W+ Z! A; G1 y7 |' m$ v
9
1 A& u0 p3 T/ M10
: o* A8 I4 o k' g L5 A/ g11: D: `7 x1 |8 a4 E I+ `* x! M, A( \
| ## ceph/src/ceph-volume/ceph_volume/terminal.py
( a3 Q' ]# r. J: Adef dispatch(mapper, argv=None):- x- A2 K# u- C5 j
argv = argv or sys.argv
& j- N( p' @+ {: o for count, arg in enumerate(argv, 1):
f. O* p# | g* b4 O: \- o if arg in mapper.keys():
5 a* ^, j. z5 ?9 X8 K ## 创建实例
! h4 B3 A+ K' x b instance = mapper.get(arg)(argv[count:])
" e3 F: y- ~* L if hasattr(instance, 'main'):
% D K, p8 h) Y. O' o ## 实例main方法3 |! E8 n& A- w+ C( b5 q
instance.main()4 ?0 B' d$ X h2 c& e
raise SystemExit(0)
( K* m- x! }; S1 ^; ]) r; ] |
显然根据传入的参数创建了LVM的实例,然后进入实例的main方法 1( L; a: w4 m4 v" C. N6 B7 r
2
) Y, P# X5 G' s+ c3+ M. i' {! X) q0 N
45 B% l# u0 d; ~- |0 s* z" K) ]
5
0 n5 p. ~# o( ]+ N; K/ H2 z6! G- V. P# D4 I: R/ q9 A) u) |
78 C; R3 ~% [1 G5 k! J
8
6 S4 K; Y& U. j9% H- M: L4 P! ?. M' U0 ^
10
, p% @- ^$ |6 }9 ^% s) D) _11
4 z8 ], ]+ ~& V12
# L9 A3 e9 u/ u7 q" B' w1 e13
' p. [6 u# r/ k4 T2 K. [: s% l3 e. x14
! e. |1 A+ Y: T6 I5 Q, w | ## ceph/src/ceph-volume/ceph_volume/devices/lvm/main.py
1 b% t% f/ Z$ ~0 S2 `4 Yclass LVM(object): ' Q/ k. @9 y) X o# A+ h' v& r
mapper = {2 E b% X& ?5 t/ H, L
'activate': activate.Activate,: A: L8 l3 V# \$ E& `
'batch': batch.Batch,- ^) _: d/ |# w0 M9 q# z) c C
'prepare': prepare.Prepare,6 K! h, z, Q5 S+ L) q5 p" o
'create': create.Create,! s, `+ A( \. z( t& P! {$ E
'trigger': trigger.Trigger, ### 关注这里### . A T- b9 i- Y6 c3 h6 D" I* I
'list': listing.List,: |2 ~' M: v- O% J, _& C
'zap': zap.Zap,
% @+ m) h: f$ L9 Z A9 E0 s: u }" M$ [! U7 N' H" u# p7 G& P
def main(self):2 Q1 D' i& A; w: p% a+ ~
terminal.dispatch(self.mapper, self.argv)
& G. }. g3 u6 W# z7 v* F& |1 |. C ...<中间省略>
$ \, `8 K$ w4 C# c* ]- n1 b |
跟前面如出一辙,根据传入的参数对应进入trigger.Trigger实例的main方法 1
/ e4 P# V4 k" y4 i2
, T a+ @* K9 ?9 x3
) w* ~* I* L1 W3 k4" X& \% Z! y0 S" y1 z! e
5
3 x+ V' s6 u% b8 R) M' i6
8 l; P2 `2 m( I7 s/ S* E' i. g7
R% B* \% m$ n" _8
% a i0 j9 ?' {3 |& D2 q9
) K/ Y1 t8 R2 A3 S108 Q; E* ~; L, e- Q9 x [5 N; N
11
" N+ c. Z6 \$ @) k! s6 T- M }12
9 W0 ^8 @: r* U. D2 \2 Z13
! p0 O; q3 S3 e; N142 q7 l6 ~8 S# D8 W2 s
15
" Z9 C) n% I# g' K c166 A3 D% y* L. R, ~2 x. e5 x
174 \ s) ?) a, P% k. U! a/ _) O
18
$ E9 |3 \' h" z i198 A% b0 L3 v) W2 O4 }
| ## ceph/src/ceph-volume/ceph_volume/devices/lvm/trigger.py1 W; u I. k1 o1 k i) n/ E" C
class Trigger(object):
5 p0 Z- R& \' v' z
9 r8 s4 b4 F7 r6 \; r; J: t0 p7 T help = 'systemd helper to activate an OSD'6 |/ D9 [- Q- G/ |+ ~
/ D6 Q8 C. P( e6 |" B
def __init__(self, argv):/ \! Q: {8 v/ J5 t3 [: s8 f
self.argv = argv* e( {0 I* g) U9 O0 \! ]
2 v0 ~" X: M1 n4 f @decorators.needs_root- D8 E* f; _8 |+ F
def main(self):
! K) Y) s5 H! C" j. m( n3 l ... <中间省略>
k. ?+ G2 I) t3 w- ] ## 解析参数
3 T% e. v& ` v! b; _7 ` args = parser.parse_args(self.argv)# U; @$ W2 T, \: K, q
## 检验osd id
6 ~5 }. f; ?4 a( L. f- p+ A osd_id = parse_osd_id(args.systemd_data)
) U8 x$ X/ z) g- D4 Y ## 检验uuid' R; R4 }% H' c( v' P
osd_uuid = parse_osd_uuid(args.systemd_data)
' Y6 C# v) [3 T ## 再次跳转到Activate实例main方法
8 X/ w( @1 v# X Activate(['--auto-detect-objectstore', osd_id, osd_uuid]).main()+ d/ E: Q' W" b8 ~6 b% X6 H' N% H
|
以下是Activate类的main方法 12 g1 S# {3 Z( m1 t( u
2' V& x# Q$ j" O. n0 _- |( S
3
- w) \! J8 O# D. o" u9 J4
( T% f4 U0 ~- i# s* R! a5, A, k* \$ x" j! ~$ G
65 a3 N8 x, Q! O/ G7 t, Q
7( c" V) l4 M* E1 W
88 F# d* g3 g. I
9
/ \8 F9 K/ X3 Z$ B102 `2 G6 v6 G/ H+ J
111 e& d6 P9 C( s6 \+ y% w
12
! S; W8 z6 j& h0 ~" P13' }1 d" ~% ?+ k. x# h
14
6 i; O, G9 S7 A/ W" p | ##ceph/src/ceph-volume/ceph_volume/devices/lvm/activate.py
# |& u2 S- n/ {9 y5 Z- ldef main(self):
/ ]3 B# n" }) L( M: M# | sub_command_help = dedent("""
7 G0 C3 @: E( y3 t/ [) Z5 u- B8 A ...<中间省略>: m$ c2 @& B5 u3 m! @
)* X+ b+ B2 W7 `1 i9 r& G! a
## 参数解析
% [& I) K; A# M& _' ^ args = parser.parse_args(self.argv)2 ?0 m8 e$ ]7 c6 ]2 b. ~
## 如果不指定是bluestore或者filestore,默认按bluestore来处理- A, G& c1 y! ], A3 M6 s
if not args.bluestore and not args.filestore:, v2 ~3 ?. o* K1 b% X$ Y7 L5 K
args.bluestore = True
8 O) r2 u1 r/ Q! R/ _ if args.activate_all:3 I) a! B/ k2 I7 O9 M! L/ I
self.activate_all(args)
7 I6 e" u% \& v0 \4 e& X else:: Z5 p8 h: w- A1 k, d2 i6 g. W- I8 m6 ~8 N: l
self.activate(args)
0 r) {8 m# U$ M$ O$ o- X" B! e/ L |
最后通过实例的activate方法来激活 14 [% y- J# |5 y" G# n4 g/ j
2
$ B' K. h" H I9 P3( E) s) S7 _1 F9 g" p1 d
4
@$ u2 R, R4 Z" _2 F5
- l% T) z0 g+ o/ D3 F3 P6
+ @7 v c2 Z, j" F+ B7
5 N4 D4 q5 v6 e, A. p8
1 U$ @% [% G/ T, G6 s$ B9( H& k1 I. T8 p; m+ N& X. E
10
- T. Y4 `/ D4 d4 s4 G. _11/ V9 _ B' ` \
126 o# c* [" p* F- @0 [
13
) ]( L4 }! h, d$ f* h. v* ?0 m14, d' d$ g5 T. U8 l
| ##ceph/src/ceph-volume/ceph_volume/devices/lvm/activate.py
/ m$ h/ ]0 r, F: hdef activate(self, args, osd_id=None, osd_fsid=None):
2 l+ m9 e( e& j1 {1 b) V6 g s' o ...<中间省略>
a& @7 i" B# n. d8 p ## 获取本地所有的lvm卷信息
) m$ ]8 o5 W! P* V lvs = api.Volumes()& q& m. z' m4 v
...<中间省略>
" N6 w/ `, \1 {7 z- o0 o9 Z7 Q for lv in lvs:, R M* }& l6 c3 k
....$ U/ A0 B2 k3 E. k/ m
## 通过lvm的tags来判断传入的osd id跟uuid是否已经存在,这些tags是在创建osd的时候写入(请继续往下看^_^) 7 d. D& Z, v- i/ n! ~ U
return activate_bluestore(lvs)! X, Z! R9 y' [/ j0 ?; O
if args.bluestore:
- d8 x% V) }2 l7 H5 d activate_bluestore(lvs, no_systemd=args.no_systemd)4 B% A& E2 d+ a
elif args.filestore:9 B- d9 Y( Y8 v6 {1 W6 U
activate_filestore(lvs, no_systemd=args.no_systemd)) n2 O$ C+ W$ d! M! a' K
|
BlueStore的osd则继续跳转到activate_bluestore 1
' g R7 S- K# O- L28 y" u! |2 p: g; v
3: Y. k6 W. C9 q7 ~5 f u* G2 M* \
49 S& e) W7 C) q5 w
5
/ p; ? z1 V% e+ y' ?! l# Q3 ~" l6
. R1 y& S$ B3 k- u7. T; w3 F4 R' k2 g) i" ~, J
8
: ^, z5 y9 g' _" [( Q7 O8 m9
6 M3 H2 v# l: T2 k( ^! m: ^3 ~101 p; N0 H( ?" f
116 v3 Y' `! H+ a7 v
123 }3 B2 z, b3 m8 @" b$ ?5 F v
13
* b: m+ A- W+ u14/ q( ]+ ^7 P x* i$ I
155 K; @6 |+ n# w, K+ Z
16
3 r2 \) b- ~7 V17
$ G) z0 n, \) g4 `# v7 t2 Y( |% E0 Z18
# \& i$ ~1 F9 W7 g" @6 T" k6 d191 u7 T. S2 c6 k U. r2 ~
20
# _1 N, M+ [, u21* Z/ y4 T! J3 v7 u. L: f
22+ T# H+ v; f; {; L: Q' G
230 D( D3 Z$ T7 l% i( E* i
24, f G- [0 z: F$ |* P
25' q9 q% r; p1 @. H( S5 z
26
( L! n) y2 \; @. g% Z0 a [27
+ A6 W g' b0 G) t9 k28
$ D$ Z* \; Z* G# i( c' h29" z P' A* }9 v% H* U, X7 f
30
8 D+ a' y7 o/ J311 v3 } J6 d' ]8 m! _( J3 M8 _
325 o6 F. D. Q6 t! i( L* o# r5 X4 B
33; I# c8 F6 O2 ^1 L" N+ ^( M
34
. K! _4 p* r& f$ m35
0 U& U N/ l, K$ j4 a/ y3 y; R36
9 Q2 L# T& ]& I- w37' N8 U' K: ^6 G# N
38
8 ]9 \ _" {/ A* ]39
- {% c4 t, x, h8 h40, }" C- U% C' R$ \4 \) A
41
! L0 C8 `# W$ {# Z42# c% m$ r$ ~$ D, Z/ w5 |
433 b. g& n4 u+ A* u7 N- q7 f
44: o6 o S9 s; i6 R
45
T; @! ?1 l h0 |+ d46
: x' t' `8 n0 W1 J5 A47
. S$ K+ ?5 I" `# V0 L48
+ r# m4 e: C4 X3 l* i1 y4 _6 n" c492 U7 _7 @4 a# ~. h% B
50+ c& w+ t% S# b3 o2 N% a% [
51 }" N- H* }3 u6 C+ N2 X9 ]( }
52
8 t7 s# r8 S8 c) u8 B. I7 C | ##ceph/src/ceph-volume/ceph_volume/devices/lvm/activate.py
% a! }7 _& @# Y$ _9 sdef activate_bluestore(lvs, no_systemd=False):
0 F+ }" ^: m# Z$ [+ r. u # 从tags里找osd相关id、fsid、cluster_name等信息/ K. H- e6 {9 `3 v$ U& k) ?
osd_lv = lvs.get(lv_tags={'ceph.type': 'block'})9 ~, u) F- Y8 O7 ?
if not osd_lv:5 @! O; L3 ?( s# Y& ?) f b `8 W! d
raise RuntimeError('could not find a bluestore OSD to activate')4 f1 M, G' P$ F; k, j) ~. O
is_encrypted = osd_lv.tags.get('ceph.encrypted', '0') == '1'
. A5 T+ j! d3 ?0 O7 w& M dmcrypt_secret = None _: |2 x8 Y- p, d6 f5 Z) z
osd_id = osd_lv.tags['ceph.osd_id']
9 N& j7 }6 ]9 `, G8 M5 I% Y7 M Y conf.cluster = osd_lv.tags['ceph.cluster_name']
- l: h0 h- ?. Q8 n osd_fsid = osd_lv.tags['ceph.osd_fsid']
$ J0 y" P0 z; K, O) D( L0 c4 z8 L% A
osd_path = '/var/lib/ceph/osd/%s-%s' % (conf.cluster, osd_id)4 P) x( `$ x8 h: |
### 有没有很熟悉,其时就是前面分析的activate阶段的相关命令###
; f: W r3 M+ E2 C5 R: V( S! M" z3 i if not system.path_is_mounted(osd_path):% x! l" K& ?. b5 K' c
# ## 创建工作目录并挂载tmpfs * V b7 z/ z) q; j# v9 _. R8 i
prepare_utils.create_osd_path(osd_id, tmpfs=True)
0 }" m7 Y- H( Z8 D( c" ~' _) B ## 构建data、db、wal的软链路径
) `! j; H, W4 q: W/ N0 l for link_name in ['block', 'block.db', 'block.wal']:1 I0 Q9 @9 x4 g" t( o
link_path = os.path.join(osd_path, link_name)
. q0 J0 ~- } d5 Z% j+ v* y if os.path.exists(link_path):
" ^+ \9 u* Y( ` os.unlink(os.path.join(osd_path, link_name))
6 x W% B+ J8 I. J# w' m! r& f ## 获取设备路径 ##$ w" c4 h# R- U8 i, T1 Q s3 i
db_device_path = get_osd_device_path(osd_lv, lvs, 'db', dmcrypt_secret=dmcrypt_secret)
' M1 C+ }5 G& I; F" Y6 [# w wal_device_path = get_osd_device_path(osd_lv, lvs, 'wal', dmcrypt_secret=dmcrypt_secret)$ {8 e3 w+ q7 h8 H/ ?8 H8 ]' i
6 T7 H; W# v1 A# `+ K
### 看这里!看这里!看这里!重要的事情说三遍,就是调用ceph-bluestore-tool工具读出元数据并写入工作目录,一模一样,下面都一样了。很熟悉了吧 ^__^# c1 C/ \; y. Z0 M
process.run([" I9 m# p. C! l: S) @3 `1 G
'ceph-bluestore-tool', '--cluster=%s' % conf.cluster,' C" Y6 m( ^5 I, o4 M7 \1 u
'prime-osd-dir', '--dev', osd_lv_path,
& A; o; `+ }+ c+ a: @" { '--path', osd_path])
/ _% ?: Z5 U) ^2 z1 C5 A
9 X2 K1 j; Z6 Q process.run(['ln', '-snf', osd_lv_path, os.path.join(osd_path, 'block')])
, d' N" ?/ o9 C7 F ## 所有者修改以及创建软连" v* ~/ W# ~' m; B% ]( {
system.chown(os.path.join(osd_path, 'block')) h- Z: a, _% B* q, ]$ y
system.chown(osd_path)
" M) z% s+ {' k, v* W if db_device_path:
5 L# h: z2 }5 j0 k( c2 r* m+ s destination = os.path.join(osd_path, 'block.db')
) y6 N9 b+ g! Z% s: L4 P7 f" x process.run(['ln', '-snf', db_device_path, destination])% |) E! x0 ]. H/ q# ?; V' P$ R7 r$ b
system.chown(db_device_path)# x+ `. {& j3 w+ a2 D2 M
if wal_device_path:. t& y2 ]" v8 ?$ M% n- r, g; n
destination = os.path.join(osd_path, 'block.wal')8 s3 q! V1 Z! P; h* J
process.run(['ln', '-snf', wal_device_path, destination]). ]* X! t$ a; G; A" e
system.chown(wal_device_path)1 }# c5 u$ t! S1 e+ Y
3 U( C: q c3 ^9 F* R: z
if no_systemd is False:. q; P* c$ E( P: h0 J1 }
# enable the ceph-volume unit for this OSD
( Z" E$ L; ?7 X# K* @2 h systemctl.enable_volume(osd_id, osd_fsid, 'lvm'), i4 M1 G5 d5 M- `" L- e
# C9 L' @% z8 U# J* {3 R
# 启动osd进程5 e! E# H1 P( _4 H) c' M
systemctl.start_osd(osd_id)! U' F2 [$ N- ~8 K% \% u
terminal.success("ceph-volume lvm activate successful for osd ID: %s" % osd_id)6 g+ I F% X, n) ~" H
|
到此,相信大部分读者已经豁然开朗了。ceph-volume系统服务会触发ceph-volume lvm trigger, 再进入activate阶段,最后一系列的系统命令调用,完成osd启动。 整个启动流程大致如下图所示:
9 y5 `* }" w: S; ?; k; c2 _image_1cn8kcnnbh521niu16djegnqhb4d.png-40.8kB 创建分析osd的创建跟启动代码入口是一样的,都是从ceph/src/ceph-volume/main的main()开始 image_1cn8melrej3a5glk0c1cpqeqv4q.png-21.5kB3 e7 s8 t+ D$ g; d9 V% M! f3 W
根据传入的mapper和argv,再次回看下terminal.py里的dispatch 1
1 C, q9 ]( W+ Y" o6 e; h2
, W. t4 Z! i% d7 Z# }36 o8 _9 y! F; B$ I$ y2 E/ E
4" C. m% W9 Q- F! a0 Z
5
$ v4 H* u0 X N0 {- ~+ i6 _! x# j6$ t F/ x$ f" H3 k% P# R) M% R
7" H/ k t/ X9 O0 ]8 y1 s
8
8 w& z* f3 ~5 @" i+ W1 S; ~) Z! p6 ^9) P, o8 n3 Z; b `1 o
10
; x9 [, a) {5 O. \" e; C11
' |7 L' [! Y+ x& T9 t% t) m | ## ceph/src/ceph-volume/ceph_volume/terminal.py
# m6 v) h+ @1 Q/ d- e. [/ q/ @& C+ r/ gdef dispatch(mapper, argv=None):1 ~5 s8 Y: ]4 L: W# n9 y( @ R
argv = argv or sys.argv
# X( z: V. Z/ m& K for count, arg in enumerate(argv, 1):
. X& C8 `2 {4 O# R1 d# A; _ if arg in mapper.keys():/ N' [7 m5 a3 f- m$ S
## 创建实例4 g, D5 D: `- W X8 a) U+ p
instance = mapper.get(arg)(argv[count:])2 z9 m* v6 K3 W
if hasattr(instance, 'main'):
/ L Q Z. H1 \ ## 实例main方法
) k: K+ u! u, Y) H: H, t9 t5 j instance.main(): q" k7 J8 h* M$ p0 B% k. J
raise SystemExit(0)
! a8 V# P0 l$ x4 F" S, L |
如下图所示的LVM的类变量mapper,结合上面内容,实例instacne实际上就是create.Create(),然后执行实例的main()方法, m! M; p' H1 H, r0 x- V/ I
image_1cn8i7f3l12b61ap1i0a1u1h124440.png-65.5kB 1
7 R J+ j( X; @4 S3 l: b ?) |2: d/ a. E0 P! @! `% J t7 A
3% a# ~8 |) e7 e
4
F/ z/ N4 ~% p: }5, A& l+ |6 y0 d5 \7 Z R3 H
62 R1 u- h0 Y7 c" ~7 ^( d. U# p
7% s+ {' \7 f) M1 U
8
' U$ |0 {; C4 R# m2 k ]. L90 b; b* d) Z7 e; B
100 F! \; F/ C$ Y% e( N$ y# E
119 H: a3 V. ^2 N- ~) ^/ _" [
12
, D" v2 A* |9 @9 U8 m# v2 x& S. I13
6 A% q# T4 j2 E' n14
1 R4 J& Y3 A+ i- k/ w | ## ceph/src/ceph-volume/ceph_volume/devices/lvm/create.py+ w3 L' m' ?. O: D7 ]+ l5 O
def main(self):
6 g2 _! v) E* T# i) {& Z ... <中间省略> Z! c4 s9 T+ j7 V9 A: {' |6 J
## 解析参数
4 _7 z, s- C: \' n if len(self.argv) == 0:
7 Y h# G# [, J$ x- j! E print(sub_command_help)& e% `& R5 Q* A
return# Y- h s! O. S3 h& o% ~( i
exclude_group_options(parser, groups=['filestore', 'bluestore'], argv=self.argv)
O8 k9 ^$ a% q4 n( { args = parser.parse_args(self.argv)2 j5 A6 Q- G" W1 s& ~' ^
## 判断是bluestore还是filestore,默认为bluestore
Y6 h! [5 p: g if not args.bluestore and not args.filestore:8 u+ K! U4 J1 U! M D
args.bluestore = True
' N2 K# U* y- ]4 S( o ## 调用create()方法
& i) \2 `- |. E! o( F. Z6 @ self.create(args)
3 w/ o2 n$ _0 t |
进入create()方法,重点关注它里包含了创建Prepare实例,然后进入Activate().activate(),这在前面启动阶段已经分析了。下面重点分析下Prepare里具体做了哪些处理。 1. _* L+ m: [ f& n# Z9 o$ \+ L
2
5 E% o0 g. t; z' G( H35 G; R0 X7 Y Z! k- P
4* E4 p7 ~# k3 f' i! z
50 o% g8 ?' E/ t' t3 ?
6
# A2 w' r9 b4 ~. ~. ?) \7) |6 b, A: e& g0 V2 a: B9 g1 i6 ~
86 e7 p* y% [: P4 t% ~0 f
9
- O6 d* w M; @) |, ]: b! ~9 C: {5 p10: w. K: @8 C B0 o. y; F# H4 L
11
) t p" c% n- L, L12% c( m. T2 f6 Y; {% \; ~
13
0 s% @% F! N! U M14: e6 x. G$ f) i( h
15! }! n& C% \4 n9 k2 ~' p4 v
16
4 R3 p& p6 I7 i: B! O0 o7 A, {17
' N1 H# Q( Q8 Y0 t18
" ~% F8 {" x& v: g- d | ## ceph/src/ceph-volume/ceph_volume/devices/lvm/create.py( l1 q: N O* c& G( F2 Z
@decorators.needs_root
$ A& r6 J8 i6 N3 p1 a: Kdef create(self, args):
" D8 _& v( u" }5 y" V if not args.osd_fsid:# O+ q. x9 t7 D+ }
args.osd_fsid = system.generate_uuid()
2 i; v; L$ k) q+ u7 i- B ### 注意看这里!! 包含了prepare ###6 [! a) l& a0 x- p0 p1 ^
prepare_step = Prepare([])/ f1 L5 h$ r# `" @+ W
prepare_step.safe_prepare(args)
$ Q1 l* L( @9 Y( z7 x3 S! x osd_id = prepare_step.osd_id
0 C. ?" r3 e) C+ u. U try:) z6 i! Y5 P4 }8 i- o9 N( r% F# h K; Q
Activate([]).activate(args)0 ]4 y/ g' j# \+ m' l3 e l* \
except Exception:
9 W( a" X/ w0 _8 i2 h6 d logger.error('lvm activate was unable to complete, while creating the OSD')
# v8 a" W6 E- v; r$ E logger.info('will rollback OSD ID creation')
6 b* ^0 m# v- D8 F! o" O ## 创建失败,就回滚,删除osd,其实就是调用ceph osd purge 相关命令 ##
3 U w( e; r7 w( D' g! }" G rollback_osd(args, osd_id)& \# ~& @; A; R
raise1 r7 I: g0 ?9 L5 A
terminal.success("ceph-volume lvm create successful for: %s" % args.data)0 Q R0 q: y' v
|
1
3 Q) z6 E2 _' `9 D0 \2+ j6 _) N4 v- w) w3 H
3 Q1 c; O3 g$ |0 F3 D
4, E1 W% R$ u. w0 w* I& h: s+ A
5" q) |; _( e! U! w' C6 a
6+ j1 A' U. z! R/ e; J! G0 [9 `
7
' ^) v5 x" D4 v88 d- |2 F* U# m
9
5 S8 ]1 e7 u0 C+ m# f; U10
3 ~* H" [0 X. w; K: m* @6 y& B113 u: }( d5 D0 c2 L2 q U& D
12
8 M2 L' }/ u5 S% M; ?6 _! v" x/ k; z+ E13
* A9 k: i- N( C/ q+ C14
% v- ~/ b/ T8 K15& I8 O; d/ l+ F6 N) [ Z+ u
162 E y. H; z) `5 `% z+ s; t% @: U
17
! |- R1 R5 Y8 O18% L( c* n: N+ @" ~, i& y7 e: R4 F
19
; @; M M/ |$ Z( g" j20: c6 \# L8 g, E4 J3 V! }
21
7 G0 q. L, T) y$ j22
" l0 r) p" e5 m9 h% g+ F23
) o4 {3 R3 j9 v9 s# d24& }3 {- i* U3 n. o* r+ h5 ~: p
25
# j- f! v7 F& W, C/ U* T26
) r) A2 q" D( f9 N0 z; D27
. ?& ~! i+ Q; d4 g& _& D5 z28+ u, q1 Y0 K& m' l8 O
29
/ m6 u0 M* V3 \+ F; F+ k8 x3 l* }30
# y: @4 o: Y6 X" R( ~7 p+ o31
! s/ Y/ v9 a, w- o. V32
3 K7 }0 h- Z- I% m) r+ y0 p% @33
, C. w* i8 ~2 a5 D1 q8 Y. M34 P5 U2 S. ]8 A4 I2 r
35 t- @0 M) ^5 F1 O
36/ o' U4 Y, E$ C- S# G2 X
37. n3 u' M- c9 t8 _- }9 ~, J
38
! t0 r E- j2 k7 _5 w39$ a3 c5 [2 G; k+ s( ~
40( A% h# y/ w" q6 k% y% O
| ##ceph/src/ceph-volume/ceph_volume/devices/lvm/prepare.py: p* @9 r8 \: _# C7 p3 @' j5 ~
@decorators.needs_root
, |" d4 B. s+ `4 M1 b( B# vdef prepare(self, args):
& X! V. f. r0 t0 E
@# ~! E- d! q! m" H) f/ K7 L ...<中间省略>
& x+ Q/ J' z- A1 A# J3 h2 O& L, h2 Q
### 创建osd的一些准备工作,比如keyring,osd id,osd uuid等
, g; k1 s( o2 W' N3 @ cluster_fsid = conf.ceph.get('global', 'fsid'); ~0 A( c3 Y2 S* ~
osd_fsid = args.osd_fsid or system.generate_uuid()
9 ^7 J9 d5 n9 U crush_device_class = args.crush_device_class
# a9 U3 c. \% x if crush_device_class:: {& M7 \6 m4 {/ |
secrets['crush_device_class'] = crush_device_class
4 e+ l: W/ N' x; m! j self.osd_id = prepare_utils.create_id(osd_fsid, json.dumps(secrets), osd_id=args.osd_id)
# ?( s6 P- t- Q. Q7 N ## 这些元数据打包到tags里
4 z; o, H) W2 v( i tags = {* a9 O; S' W4 p+ w: r
'ceph.osd_fsid': osd_fsid,
! r0 Y* P0 a+ J* g' L& y 'ceph.osd_id': self.osd_id,
L! G7 a2 U9 ^/ w5 R' L7 d 'ceph.cluster_fsid': cluster_fsid," `# G m3 c: Z
'ceph.cluster_name': conf.cluster,
7 w! T- p! W2 W# `9 n1 e9 _ 'ceph.crush_device_class': crush_device_class,
0 B- y. J1 B n7 q; a }; s) J/ u5 b. `# D
...<中间省略>
1 E" G9 {2 l2 N: n #### 看重点!!!根据传入的数据先去扫描本地所有lvm卷信息,是否已经存在,如果没有,就把这些tags写入lvm的tags里
9 ?1 p, z: {" y& I( [ data_lv = self.get_lv(args.data)% z" D0 q! S) {" w% L) S- g$ z5 o
if not data_lv:$ ~0 I" n. [& x) i5 ^2 G* \
### prepare_device方法里会把tags写入到lvm卷的tags# R, C( f# i+ o
data_lv = self.prepare_device(args.data, 'data', cluster_fsid, osd_fsid)
9 B3 K0 B* F- d8 |$ T
2 Q S6 j% Z$ P( ` ...<中间省略>
" D0 D9 f7 q6 z* s
% l5 `" m. T3 R2 h #### bluestore 初始化准备,跳转进入preabluestore继续处理
. g/ ]4 D$ f9 ^$ i. { prepare_bluestore(
* a0 Q/ F Z; Y; ] block_lv.lv_path,# u0 [) q: L8 k. K# b4 w
wal_device,
3 w7 Q$ q& s, a: M6 S$ X4 j db_device,
$ ]* K+ H8 v! E secrets,
! t* Y9 d: x5 t% x tags,9 I, B; N" g( C( W
self.osd_id,
2 \$ w8 ~( S" n& ?0 g0 ^ osd_fsid,. L( n2 }' A) q+ H' T! ^* O; u5 M, ?
)
; v# H/ V- Z9 T5 G' q$ c/ E |
1
* r$ }7 x6 b- e5 _4 Q; P6 L* w2
9 T# g7 a' L( q, M8 a3
- u8 Q0 b& Y9 N1 ^0 T4) r) N6 D6 n7 o" ]; `. }4 m9 \
51 s$ p/ H" b. X8 _' h# E2 m
6
0 |6 X4 C2 F$ F7 R7 N7
, T- O' A3 ^7 ^9 I" g8
% d, |+ u$ Y/ w* D. u9
, A: e. Z% Y4 u10
) a5 H% }8 j6 {4 I6 | | ### ceph/src/ceph-volume/ceph_volume/devices/lvm/prepare.py6 b: V, k3 r0 g( x( \% O
def prepare_bluestore(block, wal, db, secrets, tags, osd_id, fsid):8 q% A: ?( l: l! U
...<中间省略>
, n* Y/ x$ M# j9 q5 g ### 其中都是一些准备工作,核心就是这个初始化了,也就是前面出面过的初始化" p6 i/ ]! q4 ]% K; a
prepare_utils.osd_mkfs_bluestore(% m5 n, i" U! O
osd_id, fsid,' b! J( ^$ v; O
keyring=cephx_secret,. m1 V b, n3 p" S: z/ L/ n1 @
wal=wal,4 w9 ]# {$ {2 J( m
db=db
; C! ?6 E; |3 Y$ v u )
! } k# g! j* r5 ^# x0 Q |
至此,bluestore已经初始化完毕了,然后接着走启动流程就可以了。( Z3 q3 ~, P% O
image_1cn8n9740i5nilf19jgjl1l1264.png-45.7kB 小结通过阅读学习ceph-volume的代码,可以清楚地理解整个osd的创建与启动流程 |