ceph集群RadosGW對象存儲使用詳解
一個完整的ceph集群,可以提供塊存儲、文件系統(tǒng)和對象存儲。
本節(jié)主要介紹對象存儲RadosGw功能如何靈活的使用
集群背景:
$ ceph -s cluster: id: f0a8789e-6d53-44fa-b76d-efa79bbebbcf health: HEALTH_OK services: mon: 1 daemons, quorum a (age 2d) mgr: a(active, since 2d) mds: cephfs:1 {0=cephfs-a=up:active} 1 up:standby-replay osd: 1 osds: 1 up (since 2d), 1 in (since 2d) rgw: 1 daemon active (my.store.a) data: pools: 10 pools, 200 pgs objects: 1.29k objects, 3.5 GiB usage: 60 GiB used, 798 GiB / 858 GiB avail pgs: 200 active+clean io: client: 852 B/s rd, 1 op/s rd, 0 op/s wr
什么是對象存儲
- 對象存儲,又稱鍵值存儲,通過其接口指令,例如簡單的GET、PUT、DEL等,向存儲服務上傳下載數據;
- 對象存儲中所有數據都被認為是一個對象。所以,任何數據都可以存入對象存儲中,如圖片、視頻、音頻等;
- 常見的對象存儲廠商有Swift、S3等,ceph就支持Swift API和AWS S3兩種標準。
ceph對象存儲的構成
Ceph對象存儲是通過 RGW組件 來實現,什么是 rgw 呢?
- rgw全稱Rados Gateway,是一種服務,使客戶端能夠利用標準對象存儲API來訪問ceph對象網關;
- ceph 0.8版本之后使用Civeweb的web服務器來響應api請求,說白了,rgw里邊就是一個web服務;
- 客戶端使用http/https協(xié)議通過RESTful API與rgw通信;
- rgw通過librados與ceph集群通信,利用cephx加密協(xié)議與ceph存儲通信;
- rgw通過bucket來實現數據存儲和多用戶的隔離;
- 可以部署多個rgw,實現負載均衡及高可用。
ceph RadosGW中有一個bucket桶的概念,一般項目或者分類會使用bucket來進行隔離,bucket的權限控制,想要操作某個bucket,操作用戶必須有對此bucket的對應操作權限,bucket最終的數據其實還是通過PG來落盤到后端的osd存儲中的。
RadosGW存儲池作用
rgw安裝流程請參考之前的部署文檔,此處不在贅述,默認端口7480,能夠curl通就表示安裝成功:
$ curl 10.153.204.13:30080 <?xml version="1.0" encoding="UTF-8"?><ListAllMyBucketsResult xmlns="http://s3.amazonaws.com/doc/2006-03-01/"><Owner><ID>anonymous</ID><DisplayName></DisplayName></Owner><Buckets></Buckets></ListAllMyBucketsResult>
我這里更改了默認端口,改為了30080
rgw安裝完畢后,會有一些默認創(chuàng)建的存儲池:
$ ceph osd lspools | grep rgw .rgw.root my-store.rgw.control my-store.rgw.meta my-store.rgw.log my-store.rgw.buckets.index my-store.rgw.buckets.non-ec my-store.rgw.buckets.data
這些存儲池也是分為兩種類型的,一種是元數據存儲池,一種是數據存儲池:
.rgw.root : 包含realm(領域信息),比如zone和zonegroup。
rgw.log:存儲日志信息,用戶記錄各種log信息。
rgw.control:系統(tǒng)控制池,在有數據更新時,通知其它RGW更新緩存。
rgw.meta:元數據存儲池,通過不同的名稱空間分別存儲不同的rados對象,這些名稱空間包括用戶的UID,及其Bucket映射信息的名稱空間users.uid,用戶的密鑰名稱空間users.keys,用戶的emai名稱空間users.email,用戶的subuser的名稱空間 users.swift,bucket的名稱空間root等。
rgw.buckets.index:存放bucket到object的索引信息。
rgw.buckets.non-ec:數據的額外信息存儲池。
rgw.buckets.data:存放對象的數據
RadosGW常用操作詳解
查看全部zone
$ radosgw-admin zone list { "default_info": "a06a6df5-68a4-47f0-9afa-2ac1c09aee58", "zones": [ "my-store" ] }
默認為default,我這里更改名字叫my-store
查看zone詳情
$ radosgw-admin zone get --rgw-zone=my-store { "id": "a06a6df5-68a4-47f0-9afa-2ac1c09aee58", "name": "my-store", "domain_root": "my-store.rgw.meta:root", "control_pool": "my-store.rgw.control", "gc_pool": "my-store.rgw.log:gc", "lc_pool": "my-store.rgw.log:lc", "log_pool": "my-store.rgw.log", "intent_log_pool": "my-store.rgw.log:intent", "usage_log_pool": "my-store.rgw.log:usage", "roles_pool": "my-store.rgw.meta:roles", "reshard_pool": "my-store.rgw.log:reshard", "user_keys_pool": "my-store.rgw.meta:users.keys", "user_email_pool": "my-store.rgw.meta:users.email", "user_swift_pool": "my-store.rgw.meta:users.swift", "user_uid_pool": "my-store.rgw.meta:users.uid", "otp_pool": "my-store.rgw.otp", "system_key": { "access_key": "", "secret_key": "" }, "placement_pools": [ { "key": "default-placement", "val": { "index_pool": "my-store.rgw.buckets.index", "storage_classes": { "STANDARD": { "data_pool": "my-store.rgw.buckets.data" } }, "data_extra_pool": "my-store.rgw.buckets.non-ec", "index_type": 0 } } ], "realm_id": "" }
radosgw創(chuàng)建新用戶認證
$ radosgw-admin user create --uid="vfan" --display-name="my vfan"{ "user_id": "vfan", "display_name": "my vfan", "email": "", "suspended": 0, "max_buckets": 1000, "subusers": [], "keys": [ { "user": "vfan", "access_key": "Q6VGP3LYMH99D0A9GUV0", "secret_key": "NVDfq7CBJgpUnCXKqbgVuKvI3siWNbx0sRltClA4" } ], "swift_keys": [], "caps": [], "op_mask": "read, write, delete", "default_placement": "", "default_storage_class": "", "placement_tags": [], "bucket_quota": { "enabled": false, "check_on_raw": false, "max_size": -1, "max_size_kb": 0, "max_objects": -1 }, "user_quota": { "enabled": false, "check_on_raw": false, "max_size": -1, "max_size_kb": 0, "max_objects": -1 }, "temp_url_keys": [], "type": "rgw", "mfa_ids": [] }
新建一個子用戶
為了給用戶新建一個子用戶 (Swift 接口) ,必須為該子用戶指定用戶的 ID(--uid={username}
),子用戶的 ID 以及訪問級別:
$ radosgw-admin subuser create --uid=vfan --subuser=vfan:swift --access=full { "user_id": "vfan", "display_name": "my vfan", "email": "", "suspended": 0, "max_buckets": 1000, "subusers": [ { "id": "vfan:swift", "permissions": "full-control" } ], "keys": [ { "user": "vfan", "access_key": "Q6VGP3LYMH99D0A9GUV0", "secret_key": "NVDfq7CBJgpUnCXKqbgVuKvI3siWNbx0sRltClA4" } ], "swift_keys": [ { "user": "vfan:swift", "secret_key": "GrjjD8yJgr2khUCIeRmggNMWqnganFlhMKMMom9s" } ], "caps": [], "op_mask": "read, write, delete", }
--access=full并不僅僅代表讀寫,因為他還包括訪問權限策略。
查看user列表
$ radosgw-admin user list [ "vfan", "ceph-object-user" ]
禁用或啟動一個用戶
創(chuàng)建賬戶后,默認是啟用狀態(tài),可以將其設置為關閉狀態(tài):
## 停用一個用戶 $ radosgw-admin user suspend --uid=vfan ## 啟用一個用戶 $ radosgw-admin user enable --uid=vfan
主要是用戶中的"suspended"值發(fā)生了變化,開啟為0,關閉為1。
添加或刪除 用戶管理權限
## 添加 $ radosgw-admin caps add --uid=vfan --caps="users=*" ## 刪除 $ radosgw-admin caps rm --uid=vfan --caps="users=write"
--caps="[users|buckets|metadata|usage|zone]=[*|read|write|read, write]"
刪除用戶 或 子用戶
## 刪除用戶 $ radosgw-admin user rm --uid=vfan ## 刪除子用戶 $ radosgw-admin subuser rm --subuser=vfan:swift
查看所有的bucket桶
$ radosgw-admin bucket list [ "my-test-bucket" ]
查看桶內對象
$ radosgw-admin bucket list --bucket=my-test-bucket [ { "name": "hello.txt", "instance": "", "ver": { "pool": 10, "epoch": 1 }, "locator": "", "exists": "true", "meta": { "category": 1, "size": 12, "mtime": "2022-03-30T10:51:38.420295Z", "etag": "ed076287532e86365e841e92bfc50d8c", "storage_class": "", "owner": "vfan", "owner_display_name": "my vfan", "content_type": "application/octet-stream", "accounted_size": 12, "user_data": "", "appendable": "false" }, "tag": "a06a6df5-68a4-47f0-9afa-2ac1c09aee58.24132.17942", "flags": 0, "pending_map": [], "versioned_epoch": 0 } ]
查看存儲桶詳情
$ radosgw-admin bucket stats --bucket=my-test-bucket { "bucket": "my-test-bucket", "num_shards": 0, "tenant": "", "zonegroup": "fd710024-4ba3-41bb-9f96-579d8f03dd1b", "placement_rule": "default-placement", "explicit_placement": { "data_pool": "", "data_extra_pool": "", "index_pool": "" }, "id": "a06a6df5-68a4-47f0-9afa-2ac1c09aee58.24134.1", "marker": "a06a6df5-68a4-47f0-9afa-2ac1c09aee58.24134.1", "index_type": "Normal", "owner": "vfan", "ver": "0#2", "master_ver": "0#0", "mtime": "2022-03-30T10:51:38.323147Z", "creation_time": "2022-03-30T10:51:38.321498Z", "max_marker": "0#", "usage": { "rgw.main": { "size": 12, "size_actual": 4096, "size_utilized": 12, "size_kb": 1, "size_kb_actual": 4, "size_kb_utilized": 1, "num_objects": 1 } }, "bucket_quota": { "enabled": false, "check_on_raw": false, "max_size": -1, "max_size_kb": 0, "max_objects": -1 } }
查看用戶配額
$ radosgw-admin user info --uid=vfan | grep -A 5 "quota" "bucket_quota": { "enabled": false, "check_on_raw": false, "max_size": -1, "max_size_kb": 0, "max_objects": -1 -- "user_quota": { "enabled": false, "check_on_raw": false, "max_size": -1, "max_size_kb": 0, "max_objects": -1
默認這些配額都是未激活的,處于false狀態(tài)。
激活用戶配額
$ radosgw-admin quota enable --quota-scope=user --uid=vfan $ radosgw-admin user info --uid=vfan | grep -A 5 "quota" "bucket_quota": { "enabled": false, "check_on_raw": false, "max_size": -1, "max_size_kb": 0, "max_objects": -1 -- "user_quota": { "enabled": true, "check_on_raw": false, "max_size": -1, "max_size_kb": 0, "max_objects": -1
已激活用戶配額,此時可以修改最大限額,默認是不限制。
更新配額
$ radosgw-admin quota set --uid=vfan --quota-scope=user --max-objects=10000 --max-size=107374182400 [cephadmin@yq01-aip-aikefu10.yq01.baidu.com ~]$ radosgw-admin user info --uid=vfan | grep -A 5 "quota" "bucket_quota": { "enabled": false, "check_on_raw": false, "max_size": -1, "max_size_kb": 0, "max_objects": -1 -- "user_quota": { "enabled": true, "check_on_raw": false, "max_size": 107374182400, "max_size_kb": 104857600, "max_objects": 10000
max_size單位是bytes,max_size_kb單位是kb。
操縱radosgw
一般對象存儲都由開發(fā)在代碼層面控制,幾乎不需要我們運維人員操作什么,只需要把用戶權限和集群維護好就沒啥問題了,接下來用一段python代碼來演示其bucket以及增刪文件的操作。也有一些命令可以實現,例如s3cmd等。
需要先安裝好python3環(huán)境,以及python的boto模塊
# pip3 install boto-2.41.0-py2.py3-none-any.whl
如果沒有pip源,離線下載地址:https://pypi.org/simple/boto/
python腳本編寫
這里測試使用上邊演示新創(chuàng)建的用戶vfan
vi ceph-s3.py
import boto.s3.connection access_key = 'Q6VGP3LYMH99D0A9GUV0' #創(chuàng)建S3用戶時返回的AK secret_key = 'NVDfq7CBJgpUnCXKqbgVuKvI3siWNbx0sRltClA4' #S3用戶的SK host = '10.153.204.13' # RWG節(jié)點IP和端口 port = 30080 # 新建一個連接 conn = boto.connect_s3( aws_access_key_id=access_key, aws_secret_access_key=secret_key, host=host, port=port, is_secure=False, calling_format=boto.s3.connection.OrdinaryCallingFormat(), ) # 新建一個Bucket bucket = conn.create_bucket('my-vfan-bucket') # 列出用戶的所有Bucket for bucket in conn.get_all_buckets(): print("桶名稱: %s, 創(chuàng)建時間: %s" %(bucket.name,bucket.creation_date)) # 列出Bucket內容 for key in bucket.list(): print("key名稱: %s, 文件大小: %s, 修改時間: %s" %(key.name,key.size,key.last_modified)) # 新建一個對象 key = bucket.new_key('hi.txt') key.set_contents_from_string('Hello World!') # 下載一個對象到文件 key = bucket.get_key('hi.txt') key.get_contents_to_filename('/tmp/hi.txt')
執(zhí)行py腳本
# python3 ceph-s3.py 桶名稱: my-test-bucket, 創(chuàng)建時間: 2022-03-30T10:51:38.321Z 桶名稱: my-vfan-bucket, 創(chuàng)建時間: 2022-04-01T07:32:54.671Z # cat /tmp/hi.txt Hello World!
已經新創(chuàng)建了一個名為my-vfan-bucket的bucket,并新建了一個對象hi.txt,并下載到了本地的/tmp目錄下。
可以優(yōu)化一下腳本,使其可以單項操作
#!/usr/bin/python # -*- coding: utf-8 -*- """ @Time : 2021-12-22 19:14 @Author : xxxxxx @Email : xxxxxx @File : bucket.py @Software: PyCharm """ import boto import boto.s3.connection class Bucket(): """ ceph中bucket相關的類 boto s3 api手冊:http://boto.readthedocs.org/en/latest/ref/s3.html boto s3 api用法:https://docs.ceph.com/en/latest/radosgw/s3/python/# """ def __init__(self, ak, sk, host, port): self.ak = ak self.sk = sk self.host = host self.port = port self.conn = boto.connect_s3(aws_access_key_id=self.ak, aws_secret_access_key=self.sk, host=self.host, port=self.port, is_secure=False, calling_format=boto.s3.connection.OrdinaryCallingFormat()) print self.conn def bucketList(self): """ 獲取所有的bucketList :return: """ for bucket in self.conn.get_all_buckets(): print("{name}\t{created}".format(name=bucket.name, created=bucket.creation_date)) def bucketCreate(self, bucketName): """ 創(chuàng)建bucket :return: """ createRes = self.conn.create_bucket(bucketName) print createRes def bucketDelete(self): """ 刪除bucket :return: """ pass if __name__ == "__main__": """ 主函數 """ access_key = "FHPC3HED7P7J8ADFQVOD" secret_key = "Zgf01sjynnAbNS6yCO99VFphDQ6sOlmPBRRd7P2E" host = "xxxxx" port = 8000 bucketName = 'share' bucket = Bucket(access_key, secret_key, host, port) # 創(chuàng)建bucket bucket.bucketCreate(bucketName) # 查看bucket列表 # bucket.bucketList()
可以再基于此腳本優(yōu)化,增加其他功能。
RadosGW相關操作至此已演示介紹完畢,后續(xù)會陸續(xù)介紹一些自定義crush規(guī)則、pg及一些常用的參數配置。
以上就是ceph集群RadosGW對象存儲使用詳解的詳細內容,更多關于ceph RadosGW對象存儲使用的資料請關注腳本之家其它相關文章!
相關文章
centos搭建code-server配置HTTPS登錄頁自定義實現步驟
這篇文章主要為大家介紹了centos搭建code-server及配置HTTPS、登錄頁自定義實現步驟詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-05-05Typora配置PicGo時提示Failed?to?fetch的問題解決(typora圖像問題)
這篇文章主要介紹了Typora配置PicGo時提示Failed?to?fetch的問題解決(typora圖像問題),本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2023-04-04Atlassian系列產品及插件激活方法[JIRA8.19.0+]
Atlassian家有很多產品,都真的非常好用。比如公司使用JIRA做項目管理,使用Confluence做文檔、知識管理等(我個人用它來做筆記)。本文給大家分享Atlassian系列產品及插件激活方法[JIRA8.19.0+],感興趣的朋友參考下吧2021-12-12