Tarantool を使用すると、超高速データベースとそれらを操作するアプリケーションを組み合わせることができます。 こんなに簡単にできるんですね

XNUMX 年前、Tarantool を使ってみましたが、うまくいきませんでした。 しかし、最近私はウェビナーを開催し、Hadoop と MapReduce の仕組みについて話しました。 そこで彼らは私に質問をしました。「このタスクに Tarantool を使用しないのはなぜですか?」

好奇心から、私はこのプロジェクトに戻って最新バージョンをテストすることにしました。そして今回はこのプロジェクトがとても気に入りました。 ここでは、Tarantool で簡単なアプリケーションを作成し、ロードしてパフォーマンスをチェックする方法を説明します。これで、すべてがいかに簡単で優れているかがわかるでしょう。

タランツールとは

Tarantool は、自身を超高速データベースとして位置づけています。 そこに必要なデータを置くことができます。 さらに、それらをレプリケートしてシャードする (つまり、膨大な量のデータを複数のサーバーに分割し、それらの結果を結合する) ことで、フォールト トレラントなマスター間接続を作成します。

XNUMX 番目に、これはアプリケーション サーバーです。 この上にアプリケーションを作成したり、データを操作したり、たとえば、特定のルールに従ってバックグラウンドで古いレコードを削除したりできます。 データを処理する Http サーバーを Tarantula で直接作成できます。その量を指定し、そこに新しいデータを書き込み、すべてをマスターに還元します。

私は、彼らがどのようにして 300 行のメッセージ キューを作成したかについての記事を読みました。これは単にバーストして急いでいるだけであり、20 秒あたり 000 メッセージの最低パフォーマンスがあります。 ここでは、実際に方向転換して、非常に大規模なアプリケーションを作成できます。PostgreS の場合のように、それはストレージではありません。

この記事では、このサーバーのようなものについて、簡単に説明してみます。

インストール

テストのために、20 つの標準仮想マシン (18.04 GB ハード ドライブ、Ubuntu 2) を起動しました。 4 つの仮想 CPU と XNUMX GB のメモリ。

Tarantool をインストールします。bash スクリプトを実行するか、リポジトリを追加して apt get install Tarantool を実行します。 スクリプトへのリンク - (curl -L https://tarantool.io/installer.sh | VER=2.4 sudo -E bash)。 次のようなコマンドがあります。

タランツールctl — Tarantula インスタンスを管理するためのメイン コマンド。
/etc/tarantool - ここに全体の構成があります。
var/log/tarantool - ここにログがあります。
var/lib/tarantool — データはここにあり、インスタンスに分割されます。

「instance-available」フォルダーと「instance-enable」フォルダーがあります。このフォルダーには、起動されるものが含まれています。lua コードを含むインスタンス構成ファイル。これには、リッスンするポート、使用可能なメモリー、ビニール エンジンの設定、起動時に実行されるコードが記述されています。サーバー、シャーディング、キュー、古いデータの削除など。

インスタンスは PostgreS と同じように動作します。 たとえば、異なるポートでハングするデータベースのコピーを複数実行するとします。 複数のデータベース インスタンスが XNUMX 台のサーバー上で起動され、異なるポートでハングしていることがわかりました。 それらは完全に異なる設定を持つ場合があります。XNUMX つのインスタンスは XNUMX つのロジックを実装し、XNUMX 番目のインスタンスは別のロジックを実装します。

インスタンス管理

Tarantula インスタンスを管理できる tarantoolctl コマンドがあります。 たとえば、tarantoolctl check サンプルは構成ファイルをチェックし、構文エラーがなければファイルは正常であると判断します。

インスタンスのステータスを確認できます (tarantoolctl ステータスの例)。 同様に、開始、停止、再起動を行うことができます。

インスタンスが実行されたら、XNUMX つの方法でインスタンスに接続できます。

1. 管理コンソール

デフォルトでは、Tarantool はソケットを開き、通常の ASCII テキストがそこに送信されて Tarantool を制御します。 コンソールへの接続は常に管理ユーザーで行われ、認証は行われないため、Tarantula を管理するためにコンソール ポートを外部化する必要はありません。

この方法を使用して接続するには、Tarantoolctl にインスタンス名を入力する必要があります。 このコマンドはコンソールを起動し、管理者ユーザーとして接続します。 コンソール ポートは決して外部に公開しないでください。ユニット ソケットとして残しておくことをお勧めします。 そうすれば、ソケットへの書き込みアクセス権を持つユーザーだけが Tarantula に接続できるようになります。

このメソッドは管理上の必要があります。 データを操作するには、XNUMX 番目の方法であるバイナリ プロトコルを使用します。

2. バイナリプロトコルを使用して特定のポートに接続する

設定には、外部通信用のポートを開く listen ディレクティブが含まれています。 このポートはバイナリ プロトコルで使用され、そこで認証が有効になります。

この接続には、tarantoolctl connect to ポート番号が使用されます。 これを使用すると、リモート サーバーに接続し、認証を使用し、さまざまなアクセス権を与えることができます。

データ記録とボックスモジュール

Tarantool はデータベースとアプリケーション サーバーの両方であるため、さまざまなモジュールがあります。 私たちはボックス モジュールに興味があります。これはデータの操作を実装しています。 ボックスに何かを書き込むと、Tarantool はデータをディスクに書き込んだり、メモリに保存したり、それに対して何か他の処理を実行します。

記録

たとえば、box モジュールに移動し、box.once 関数を呼び出します。 これにより、サーバーの初期化時に Tarantool がコードを実行するようになります。 データを保存するスペースを作成します。

local function bootstrap()
    local space = box.schema.create_space('example')
    space:create_index('primary')
    box.schema.user.grant('guest', 'read,write,execute', 'universe')

    -- Keep things safe by default
    --  box.schema.user.create('example', { password = 'secret' })
    --  box.schema.user.grant('example', 'replication')
    --  box.schema.user.grant('example', 'read,write,execute', 'space', 'example')
end

この後、データを検索できるプライマリ インデックス (primary) を作成します。 デフォルトでは、パラメータを何も指定しない場合、各レコードの最初のフィールドがプライマリ インデックスに使用されます。

次に、ゲスト ユーザーに許可を与え、その下でバイナリ プロトコル経由で接続します。 インスタンス全体で読み取り、書き込み、実行を許可します。

従来のデータベースと比較すると、ここではすべてが非常にシンプルです。 私たちにはスペース、つまりデータが単に保存される領域があります。 各レコードはタプルと呼ばれます。 MessagePack にパッケージ化されています。 これは非常に優れた形式です。バイナリであり、占有スペースが少なくなります。18 バイトに対して 27 バイトです。

彼と一緒に仕事をするのはとても便利です。 ほぼすべての行、すべてのデータ レコードにまったく異なる列を含めることができます。

Box.space コマンドを使用して、すべてのスペースを表示できます。 特定のインスタンスを選択するには、box.space の例を作成し、それに関する完全な情報を取得します。

Tarantool には、Memory と Vinyl という XNUMX つの内蔵エンジンがあります。 メモリはすべてのデータをメモリに保存します。 したがって、すべてが簡単かつ迅速に機能します。 データはディスクにダンプされ、ログ先行書き込みメカニズムもあるので、サーバーがクラッシュしても何も失われることはありません。

Vinyl は、私たちにとってより馴染みのある形式でデータをディスクに保存します。つまり、私たちのメモリよりも多くのデータを保存でき、Tarantula はそれをディスクから読み取ります。

ここではメモリを使用します。

unix/:/var/run/tarantool/example.control> box.space.example
---
- engine: memtx
  before_replace: 'function: 0x41eb02c8'
  on_replace: 'function: 0x41eb0568'
  ck_constraint: []
  field_count: 0
  temporary: false
  index:
    0: &0
      unique: true
      parts:
      - type: unsigned
        is_nullable: false
        fieldno: 1
      id: 0
      space_id: 512
      type: TREE
      name: primary
    primary: *0
  is_local: false
  enabled: true
  name: example
  id: 512
...

unix/:/var/run/tarantool/example.control>

索引：

プライマリ インデックスがなければ何も機能しないため、どのスペースに対してもプライマリ インデックスを作成する必要があります。 他のデータベースと同様に、最初のフィールドであるレコード ID を作成します。

部品：

ここでは、インデックスが何で構成されているかを示します。 これは 18 つの部分で構成されます。使用する最初のフィールドは符号なしタイプであり、正の整数です。 ドキュメントから覚えている限り、取り得る最大数は XNUMX 京です。 それは多いです。

次に、insert コマンドを使用してデータを挿入します。

unix/:/var/run/tarantool/example.control> box.space.example:insert{1, 'test1', 'test2'}
---
- [1, 'test1', 'test2']
...

unix/:/var/run/tarantool/example.control> box.space.example:insert{2, 'test2', 'test3', 'test4'}
---
- [2, 'test2', 'test3', 'test4']
...

unix/:/var/run/tarantool/example.control> box.space.example:insert{3, 'test3'}
---
- [3, 'test3']
...

unix/:/var/run/tarantool/example.control> box.space.example:insert{4, 'test4'}
---
- [4, 'test4']
...

unix/:/var/run/tarantool/example.control>

最初のフィールドは主キーとして使用されるため、一意である必要があります。 列の数に制限がないため、必要なだけデータを挿入できます。 これらは、上で説明した MessagePack 形式で指定されます。

データ出力

次に、select コマンドを使用してデータを表示できます。

{1} キーを押して Box.example.select を押すと、目的のエントリが表示されます。 キーを下げると、持っているすべてのレコードが表示されます。 それらはすべて列の数が異なりますが、ここでは原則として列の概念はなく、フィールド番号があります。

絶対にあらゆる量のデータが存在する可能性があります。 たとえば、XNUMX 番目のフィールドで検索する必要があります。 これを行うには、新しいセカンダリ インデックスを作成します。

box.space.example:create_index( ‘secondary’, { type = ‘TREE’, unique = false, parts = {{field = 2, type =’string’} }}) 

Create_index コマンドを使用します。
それをセカンダリと呼びましょう。

この後、パラメータを指定する必要があります。 インデックスの種類は TREE です。 一意ではない可能性があるため、「Unique = false」と入力します。

次に、インデックスがどの部分で構成されているかを示します。 Field はインデックスをバインドするフィールドの番号であり、文字列タイプを指定します。 そしてそれが作成されました。

unix/:/var/run/tarantool/example.control> box.space.example:create_index('secondary', { type = 'TREE', unique = false, parts = {{field = 2, type = 'string'}}})
---
- unique: false
  parts:
  - type: string
    is_nullable: false
    fieldno: 2
  id: 1
  space_id: 512
  type: TREE
  name: secondary
...

unix/:/var/run/tarantool/example.control>

これで、次のように呼び出すことができます。

unix/:/var/run/tarantool/example.control> box.space.example.index.secondary:select('test1')
---
- - [1, 'test1', 'test2']
...

保存する

インスタンスを再起動し、データを再度呼び出そうとすると、データが存在しないことがわかります。すべてが空です。 これは、Tarantool がチェックポイントを作成し、データをディスクに保存するために発生しますが、次の保存まで作業を停止すると、すべての操作が失われます。最後のチェックポイント (たとえば、XNUMX 時間前) から回復するためです。

常に 20 GB をディスクにダンプするのは得策ではないため、毎秒保存することもできません。

この目的のために、ログ先行書き込みの概念が発明され、実装されました。 この機能を使用すると、データが変更されるたびに、小さな先行書き込みログ ファイルにエントリが作成されます。

チェックポイントまでの各エントリが保存されます。 これらのファイルには、サイズを設定します (たとえば、64 MB)。 いっぱいになると、XNUMX 番目のファイルへの録音が開始されます。 再起動後、Tarantool は最後のチェックポイントから復元され、停止するまで以降のすべてのトランザクションがロールオーバーされます。

このような記録を実行するには、box.cfg 設定 (example.lua ファイル内) でオプションを指定する必要があります。

wal_mode = “write”;

データ使用量

ここまでに書いた内容を使用すると、Tarantula を使用してデータを保存でき、データベースとして非常に高速に機能します。 そして今、ケーキの飾り付けは、これらすべてを使ってできることです。

アプリケーションの作成

たとえば、タランチュラ用に次のアプリケーションを書いてみましょう。

スポイラーの下のアプリケーションを参照してください

box.cfg {
    listen = '0.0.0.0:3301';
    io_collect_interval = nil;
    readahead = 16320;
    memtx_memory = 128 * 1024 * 1024; -- 128Mb
    memtx_min_tuple_size = 16;
    memtx_max_tuple_size = 128 * 1024 * 1024; -- 128Mb
    vinyl_memory = 128 * 1024 * 1024; -- 128Mb
    vinyl_cache = 128 * 1024 * 1024; -- 128Mb
    vinyl_max_tuple_size = 128 * 1024 * 1024; -- 128Mb
    vinyl_write_threads = 2;
    wal_mode = "write";
    wal_max_size = 256 * 1024 * 1024;
    checkpoint_interval = 60 * 60; -- one hour
    checkpoint_count = 6;
    force_recovery = true;
    log_level = 5;
    log_nonblock = false;
    too_long_threshold = 0.5;
    read_only   = false
}

local function bootstrap()
    local space = box.schema.create_space('example')
    space:create_index('primary')

    box.schema.user.create('example', { password = 'secret' })
    box.schema.user.grant('example', 'read,write,execute', 'space', 'example')

    box.schema.user.create('repl', { password = 'replication' })
    box.schema.user.grant('repl', 'replication')
end

-- for first run create a space and add set up grants
box.once('replica', bootstrap)

-- enabling console access
console = require('console')
console.listen('127.0.0.1:3302')

-- http config
local charset = {}  do -- [0-9a-zA-Z]
    for c = 48, 57  do table.insert(charset, string.char(c)) end
    for c = 65, 90  do table.insert(charset, string.char(c)) end
    for c = 97, 122 do table.insert(charset, string.char(c)) end
end

local function randomString(length)
    if not length or length <= 0 then return '' end
    math.randomseed(os.clock()^5)
    return randomString(length - 1) .. charset[math.random(1, #charset)]
end

local http_router = require('http.router')
local http_server = require('http.server')
local json = require('json')

local httpd = http_server.new('0.0.0.0', 8080, {
    log_requests = true,
    log_errors = true
})

local router = http_router.new()

local function get_count()
 local cnt = box.space.example:len()
 return cnt
end

router:route({method = 'GET', path = '/count'}, function()
    return {status = 200, body = json.encode({count = get_count()})}
end)

router:route({method = 'GET', path = '/token'}, function()
    local token = randomString(32)
    local last = box.space.example:len()
    box.space.example:insert{ last + 1, token }
    return {status = 200, body = json.encode({token = token})}
end)

prometheus = require('prometheus')

fiber = require('fiber')
tokens_count = prometheus.gauge("tarantool_tokens_count",
                              "API Tokens Count")

function monitor_tokens_count()
  while true do
    tokens_count:set(get_count())
    fiber.sleep(5)
  end
end
fiber.create(monitor_tokens_count)

router:route( { method = 'GET', path = '/metrics' }, prometheus.collect_http)

httpd:set_router(router)
httpd:start()

文字を定義するテーブルを lua で宣言します。 このプレートは、ランダムな文字列を生成するために必要です。

local charset = {}  do -- [0-9a-zA-Z]
    for c = 48, 57  do table.insert(charset, string.char(c)) end
    for c = 65, 90  do table.insert(charset, string.char(c)) end
    for c = 97, 122 do table.insert(charset, string.char(c)) end
end

その後、関数randomStringを宣言し、括弧内に長さの値を指定します。

local function randomString(length)
    if not length or length <= 0 then return '' end
    math.randomseed(os.clock()^5)
    return randomString(length - 1) .. charset[math.random(1, #charset)]
end

次に、http ルーターと http サーバーを Tarantula サーバー (JSON) に接続し、クライアントに送信します。

local http_router = require('http.router')
local http_server = require('http.server')
local json = require('json')

この後、すべての http サーバー インターフェイスのポート 8080 で開始し、すべてのリクエストとエラーをログに記録します。

local httpd = http_server.new('0.0.0.0', 8080, {
    log_requests = true,
    log_errors = true
})

次に、GET メソッドによるリクエストがポート 8080 /count に到着した場合に、200 行から関数を呼び出すように、route を宣言します。 ステータス (404、403、XNUMX、または指定したその他) を返します。

router:route({method = 'GET', path = '/count'}, function()
    return {status = 200, body = json.encode({count = get_count()})}
end)

本文では json.encode を返し、その中で count と getcount を示します。これは呼び出され、データベース内のレコードの数を示します。

第2の方法

router:route({method = 'GET', path = '/token'}, function() 
    local token = randomString(32) 
    local last = box.space.example:len() 
    box.space.example:insert{ last + 1, token } 
    return {status = 200, body = json.encode({token = token})}
end)

列のどこに router:route({メソッド = 'GET', パス = '/token'}, function() 関数を呼び出してトークンを生成します。

ひも ローカルトークン = ランダム文字列(32) 32 文字のランダムな文字列です。
列をなして local last = box.space.example:len() 最後の要素を取り出します。
そして列の中で box.space.example:insert{ 最後 + 1, トークン } データをデータベースに書き込みます。つまり、ID を 1 ずつ増やすだけです。ちなみに、これはこの不器用な方法だけで実行できるわけではありません。 タランチュラにはこのシーケンスがあります。

そこにトークンを書き込みます。

したがって、アプリケーションを XNUMX つのファイルに記述しました。 そこでデータを直接操作でき、ボックス モジュールが面倒な作業をすべて実行します。

http をリッスンしてデータを操作し、アプリケーションとデータの両方がすべて XNUMX つのインスタンス内にあります。 したがって、すべてが非常に早く起こります。

まず、http モジュールをインストールします。

やり方はスポイラーの下を見てください

root@test2:/# tarantoolctl rocks install http
Installing http://rocks.tarantool.org/http-scm-1.src.rock
Missing dependencies for http scm-1:
   checks >= 3.0.1 (not installed)

http scm-1 depends on checks >= 3.0.1 (not installed)
Installing http://rocks.tarantool.org/checks-3.0.1-1.rockspec

Cloning into 'checks'...
remote: Enumerating objects: 28, done.
remote: Counting objects: 100% (28/28), done.
remote: Compressing objects: 100% (19/19), done.
remote: Total 28 (delta 1), reused 16 (delta 1), pack-reused 0
Receiving objects: 100% (28/28), 12.69 KiB | 12.69 MiB/s, done.
Resolving deltas: 100% (1/1), done.
Note: checking out '580388773ef11085015b5a06fe52d61acf16b201'.

You are in 'detached HEAD' state. You can look around, make experimental
changes and commit them, and you can discard any commits you make in this
state without impacting any branches by performing another checkout.

If you want to create a new branch to retain commits you create, you may
do so (now or later) by using -b with the checkout command again. Example:

  git checkout -b <new-branch-name>

No existing manifest. Attempting to rebuild...
checks 3.0.1-1 is now installed in /.rocks (license: BSD)

-- The C compiler identification is GNU 7.5.0
-- Check for working C compiler: /usr/bin/cc
-- Check for working C compiler: /usr/bin/cc -- works
-- Detecting C compiler ABI info
-- Detecting C compiler ABI info - done
-- Detecting C compile features
-- Detecting C compile features - done
-- Found TARANTOOL: /usr/include (found version "2.4.2-80-g18f2bc82d")
-- Tarantool LUADIR is /.rocks/share/tarantool/rocks/http/scm-1/lua
-- Tarantool LIBDIR is /.rocks/share/tarantool/rocks/http/scm-1/lib
-- Configuring done
-- Generating done
CMake Warning:
  Manually-specified variables were not used by the project:

    version


-- Build files have been written to: /tmp/luarocks_http-scm-1-V4P9SM/http/build.luarocks
Scanning dependencies of target httpd
[ 50%] Building C object http/CMakeFiles/httpd.dir/lib.c.o
In file included from /tmp/luarocks_http-scm-1-V4P9SM/http/http/lib.c:32:0:
/tmp/luarocks_http-scm-1-V4P9SM/http/http/lib.c: In function ‘tpl_term’:
/usr/include/tarantool/lauxlib.h:144:15: warning: this statement may fall through [-Wimplicit-fallthrough=]
    (*(B)->p++ = (char)(c)))
    ~~~~~~~~~~~^~~~~~~~~~~~
/tmp/luarocks_http-scm-1-V4P9SM/http/http/lib.c:62:7: note: in expansion of macro ‘luaL_addchar’
       luaL_addchar(b, '\');
       ^~~~~~~~~~~~
/tmp/luarocks_http-scm-1-V4P9SM/http/http/lib.c:63:6: note: here
      default:
      ^~~~~~~
In file included from /tmp/luarocks_http-scm-1-V4P9SM/http/http/lib.c:39:0:
/tmp/luarocks_http-scm-1-V4P9SM/http/http/tpleval.h: In function ‘tpe_parse’:
/tmp/luarocks_http-scm-1-V4P9SM/http/http/tpleval.h:147:9: warning: this statement may fall through [-Wimplicit-fallthrough=]
    type = TPE_TEXT;
    ~~~~~^~~~~~~~~~
/tmp/luarocks_http-scm-1-V4P9SM/http/http/tpleval.h:149:3: note: here
   case TPE_LINECODE:
   ^~~~
In file included from /tmp/luarocks_http-scm-1-V4P9SM/http/http/lib.c:40:0:
/tmp/luarocks_http-scm-1-V4P9SM/http/http/httpfast.h: In function ‘httpfast_parse’:
/tmp/luarocks_http-scm-1-V4P9SM/http/http/httpfast.h:372:22: warning: this statement may fall through [-Wimplicit-fallthrough=]
                 code = 0;
                 ~~~~~^~~
/tmp/luarocks_http-scm-1-V4P9SM/http/http/httpfast.h:374:13: note: here
             case status:
             ^~~~
/tmp/luarocks_http-scm-1-V4P9SM/http/http/httpfast.h:393:23: warning: this statement may fall through [-Wimplicit-fallthrough=]
                 state = message;
                 ~~~~~~^~~~~~~~~
/tmp/luarocks_http-scm-1-V4P9SM/http/http/httpfast.h:395:13: note: here
             case message:
             ^~~~
[100%] Linking C shared library lib.so
[100%] Built target httpd
[100%] Built target httpd
Install the project...
-- Install configuration: "Debug"
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lua/http/VERSION.lua
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lib/http/lib.so
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lua/http/server/init.lua
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lua/http/server/tsgi_adapter.lua
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lua/http/nginx_server/init.lua
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lua/http/router/init.lua
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lua/http/router/fs.lua
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lua/http/router/matching.lua
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lua/http/router/middleware.lua
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lua/http/router/request.lua
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lua/http/router/response.lua
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lua/http/tsgi.lua
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lua/http/utils.lua
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lua/http/mime_types.lua
-- Installing: /.rocks/share/tarantool/rocks/http/scm-1/lua/http/codes.lua
http scm-1 is now installed in /.rocks (license: BSD)

root@test2:/#

実行するには prometheus も必要です。

root@test2:/# tarantoolctl rocks install prometheus
Installing http://rocks.tarantool.org/prometheus-scm-1.rockspec

Cloning into 'prometheus'...
remote: Enumerating objects: 19, done.
remote: Counting objects: 100% (19/19), done.
remote: Compressing objects: 100% (19/19), done.
remote: Total 19 (delta 2), reused 5 (delta 0), pack-reused 0
Receiving objects: 100% (19/19), 10.73 KiB | 10.73 MiB/s, done.
Resolving deltas: 100% (2/2), done.
prometheus scm-1 is now installed in /.rocks (license: BSD)

root@test2:/#

起動してモジュールにアクセスできるようになります

root@test2:/# curl -D - -s http://127.0.0.1:8080/token
HTTP/1.1 200 Ok
Content-length: 44
Server: Tarantool http (tarantool v2.4.2-80-g18f2bc82d)
Connection: keep-alive

{"token":"e2tPq9l5Z3QZrewRf6uuoJUl3lJgSLOI"}

root@test2:/# curl -D - -s http://127.0.0.1:8080/token
HTTP/1.1 200 Ok
Content-length: 44
Server: Tarantool http (tarantool v2.4.2-80-g18f2bc82d)
Connection: keep-alive

{"token":"fR5aCA84gj9eZI3gJcV0LEDl9XZAG2Iu"}

root@test2:/# curl -D - -s http://127.0.0.1:8080/count
HTTP/1.1 200 Ok
Content-length: 11
Server: Tarantool http (tarantool v2.4.2-80-g18f2bc82d)
Connection: keep-alive

{"count":2}root@test2:/#

/count はステータス 200 を示します。
/token はトークンを発行し、このトークンをデータベースに書き込みます。

速度をテストする

50 リクエストのベンチマークを実行してみましょう。 競合するリクエストは 000 件あります。

root@test2:/# ab -c 500 -n 50000 http://127.0.0.1:8080/token
This is ApacheBench, Version 2.3 <$Revision: 1807734 $>
Copyright 1996 Adam Twiss, Zeus Technology Ltd, http://www.zeustech.net/
Licensed to The Apache Software Foundation, http://www.apache.org/

Benchmarking 127.0.0.1 (be patient)
Completed 5000 requests
Completed 10000 requests
Completed 15000 requests
Completed 20000 requests
Completed 25000 requests
Completed 30000 requests
Completed 35000 requests
Completed 40000 requests
Completed 45000 requests
Completed 50000 requests
Finished 50000 requests


Server Software:        Tarantool
Server Hostname:        127.0.0.1
Server Port:            8080

Document Path:          /token
Document Length:        44 bytes

Concurrency Level:      500
Time taken for tests:   14.578 seconds
Complete requests:      50000
Failed requests:        0
Total transferred:      7950000 bytes
HTML transferred:       2200000 bytes
Requests per second:    3429.87 [#/sec] (mean)
Time per request:       145.778 [ms] (mean)
Time per request:       0.292 [ms] (mean, across all concurrent requests)
Transfer rate:          532.57 [Kbytes/sec] received

Connection Times (ms)
              min  mean[+/-sd] median   max
Connect:        0   10 103.2      0    3048
Processing:    12   69 685.1     15   13538
Waiting:       12   69 685.1     15   13538
Total:         12   78 768.2     15   14573

Percentage of the requests served within a certain time (ms)
  50%     15
  66%     15
  75%     16
  80%     16
  90%     16
  95%     16
  98%     21
  99%     42
 100%  14573 (longest request)
root@test2:/#

トークンが発行されます。 そして私たちは常にデータを記録しています。 リクエストの 99% が 42 ミリ秒で処理されました。 したがって、3500 つのコアと 2 GB のメモリを備えた小型マシンでは、4 秒あたり約 XNUMX 件のリクエストが発生します。

約 50000 トークンを選択して、その価値を確認することもできます。

http だけでなく、データを処理するバックグラウンド関数を実行することもできます。 さらに、さまざまなトリガーがあります。 たとえば、更新時に関数を呼び出したり、何かをチェックしたり、競合を修正したりできます。

スクリプト アプリケーションをデータベース サーバー自体に直接記述でき、何にも制限されず、任意のモジュールを接続し、任意のロジックを実装できます。

アプリケーション サーバーは外部サーバーにアクセスし、データを取得してデータベースに追加できます。 このデータベースのデータは他のアプリケーションで使用されます。

Tarantula はこれを自動的に行うため、別のアプリケーションを作成する必要はありません。

結論

これは大きな作品の最初の部分にすぎません。 XNUMX 番目のものは、Mail.ru グループのブログで間もなく公開される予定であり、この資料には必ずそのリンクを追加します。

これらのものをオンラインで構築し、リアルタイムで質問するイベントに参加することに興味がある場合は、視聴してください。 REBRAIN による DevOps チャネル.

クラウドに移行する必要がある場合、またはインフラストラクチャについて質問がある場合は、 お気軽にリクエストを残してください.

PS では月に 2 回の無料監査を行っており、おそらくあなたのプロジェクトもそのうちの XNUMX つとなるでしょう。

出所： habr.com