溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶(hù)服務(wù)條款》

如何將MongoDB作為循環(huán)隊(duì)列

發(fā)布時(shí)間:2021-03-15 11:07:53 來(lái)源:億速云 閱讀:183 作者:TREX 欄目:開(kāi)發(fā)技術(shù)

這篇文章主要介紹“如何將MongoDB作為循環(huán)隊(duì)列”,在日常操作中,相信很多人在如何將MongoDB作為循環(huán)隊(duì)列問(wèn)題上存在疑惑,小編查閱了各式資料,整理出簡(jiǎn)單好用的操作方法,希望對(duì)大家解答”如何將MongoDB作為循環(huán)隊(duì)列”的疑惑有所幫助!接下來(lái),請(qǐng)跟著小編一起來(lái)學(xué)習(xí)吧!

我們?cè)谑褂肕ongoDB的時(shí)候,一個(gè)集合里面能放多少數(shù)據(jù),一般取決于硬盤(pán)大小,只要硬盤(pán)足夠大,那么我們可以無(wú)休止地往里面添加數(shù)據(jù)。

然后,有些時(shí)候,我只想把MongoDB作為一個(gè)循環(huán)隊(duì)列來(lái)使用,期望它有這樣一個(gè)行為:

  1. 設(shè)定隊(duì)列的長(zhǎng)度為10

  2. 插入第1條數(shù)據(jù),它被放在第1個(gè)位置

  3. 插入第2條數(shù)據(jù),它被放在第2個(gè)位置

  4. ...

  5. 插入第10條數(shù)據(jù),它被放在第10個(gè)位置

  6. 插入第11條數(shù)據(jù),它被放在第1個(gè)位置,覆蓋原來(lái)的內(nèi)容

  7. 插入第12條數(shù)據(jù),它被放在第2個(gè)位置,覆蓋原來(lái)的內(nèi)容

  8. ...

MongoDB有一種Collection叫做capped collection,就是為了實(shí)現(xiàn)這個(gè)目的而設(shè)計(jì)的。

普通的Collection不需要提前創(chuàng)建,只要往MongoDB里面插入數(shù)據(jù),MongoDB自動(dòng)就會(huì)創(chuàng)建。而capped collection需要提前定義一個(gè)集合為capped類(lèi)型。

語(yǔ)法如下:

import pymongo

conn = pymongo.MongoClient()
db = conn.test_capped

db.create_collection('info', capped=True, size=1024 * 1024 * 10, max=5)

對(duì)一個(gè)數(shù)據(jù)庫(kù)對(duì)象使用create_collection方法,創(chuàng)建集合,其中參數(shù)capped=True說(shuō)明這是一個(gè)capped collection,并限定它的大小為10MB,這里的size參數(shù)的單位是byte,所以10MB就是1024 * 1024 * 10. max=5表示這個(gè)集合最多只有5條數(shù)據(jù),一旦超過(guò)5條,就會(huì)從頭開(kāi)始覆蓋。

創(chuàng)建好以后,capped collection的插入操作和查詢(xún)操作就和普通的集合完全一樣了:

col = db.info
for i in range(5):
  data = {'index': i, 'name': 'test'}
  col.insert_one(data)

這里我插入了5條數(shù)據(jù),效果如下圖所示:

如何將MongoDB作為循環(huán)隊(duì)列

其中,index為0的這一條是最先插入的。

接下來(lái),我再插入一條數(shù)據(jù):

data = {'index': 100, 'name': 'xxx'}
col.insert_one(data)

此時(shí)數(shù)據(jù)庫(kù)如下圖所示:

可以看到,index為0的數(shù)據(jù)已經(jīng)被最新的數(shù)據(jù)覆蓋了。

我們?cè)俨迦胍粭l數(shù)據(jù)看看:

data = {'index': 999, 'name': 'xxx'}
col.insert_one(data)

運(yùn)行效果如下圖所示:

如何將MongoDB作為循環(huán)隊(duì)列

可以看到,index為1的數(shù)據(jù)也被覆蓋了。

這樣我們就實(shí)現(xiàn)了一個(gè)循環(huán)隊(duì)列。

MongoDB對(duì)capped collection有特別的優(yōu)化,所以它的讀寫(xiě)速度比普通的集合快。

但是capped collection也有一些缺點(diǎn),在MongoDB的官方文檔中提到:

If an update or a replacement operation changes the document size, the operation will fail.

You cannot delete documents from a capped collection. To remove all documents from a collection, use the drop() method to drop the collection and recreate the capped collection.

意思就是說(shuō),capped collection里面的每一條記錄,可以更新,但是更新不能改變記錄的大小,否則更新就會(huì)失敗。

不能單獨(dú)刪除capped collection中任何一條記錄,只能整體刪除整個(gè)集合然后重建。

總結(jié)

到此,關(guān)于“如何將MongoDB作為循環(huán)隊(duì)列”的學(xué)習(xí)就結(jié)束了,希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí),快去試試吧!若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí),請(qǐng)繼續(xù)關(guān)注億速云網(wǎng)站,小編會(huì)繼續(xù)努力為大家?guī)?lái)更多實(shí)用的文章!

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI