Во Tarantool, можете да комбинирате супербрза база на податоци и апликација за работа со нив. Еве колку е лесно да се направи

Пред пет години се обидов да работам со Tarantool, но тогаш не ми успеа. Но, неодамна одржав вебинар каде што зборував за Hadoop и како функционира MapReduce. Таму ми поставија прашање: „Зошто да не го користам Tarantool за оваа задача?

Од љубопитност, решив да се вратам на него, да ја тестирам најновата верзија - и овој пат навистина ми се допадна проектот. Сега ќе ви покажам како да напишете едноставна апликација во Tarantool, да ја вчитате и да ги проверите нејзините перформанси и ќе видите колку е сè лесно и кул.

Што е Tarantool

Tarantool се позиционира како ултра брза база на податоци. Можете да ставите какви било податоци што сакате. Плус, реплицирајте ги, фрагменти - т.е. разделете огромно количество податоци на неколку сервери и комбинирајте ги резултатите од нив - направете мастер-мастер врски толерантни за грешки.

Второ, ова е сервер за апликации. Можете да ги пишувате вашите апликации на него, да работите со податоци, на пример, да бришете стари записи во позадина според одредени правила. Можете да напишете Http сервер директно во Tarantula што ќе работи со податоци: дајте ја нивната количина, да напишете нови податоци таму и да го намалите сето на главниот.

Прочитав статија за тоа како момците направија редица за пораки од 300 линии, што едноставно пука и брза - тие имаат минимална изведба од 20 пораки во секунда. Овде навистина можете да се свртите и да напишете многу голема апликација, а тоа нема да биде складирање, како во PostgreS.

Ќе се обидам да опишам нешто како овој сервер, само едноставно, во оваа статија.

Инсталација

За тестот, започнав три стандардни виртуелни машини - хард диск од 20 GB, Ubuntu 18.04. 2 виртуелни процесори и 4 гига меморија.

Го инсталираме Tarantool - стартувајте ја баш скриптата или додаваме складиште и направете го погодно инсталирање на Tarantool. Врска до скрипта - (навивам -L https://tarantool.io/installer.sh | VER=2.4 судо -Е баш). Имаме команди како што се:

tarantoolctl — главната команда за управување со примери на Тарантула.
/etc/tarantool - тука е целата конфигурација.
var/log/tarantool - еве ги трупците.
var/lib/tarantool — податоците лежат овде, а потоа се делат на примери.

Постојат папки кои се достапни за пример и овозможување на пример - го содржи она што ќе се активира - конфигурациска датотека за пример со луа код, која опишува на кои порти слуша, каква меморија е достапна за него, поставки за винил моторот, код што работи при стартување сервери, споделување, редици, бришење на застарени податоци итн.

Инстанците работат како во PostgreS. На пример, сакате да извршите неколку копии од базата на податоци што виси на различни порти. Излегува дека неколку примероци на бази на податоци се лансирани на еден сервер, кои висат на различни порти. Тие може да имаат сосема различни поставки - еден пример спроведува една логика, вториот - друг.

Управување со инстанци

Ја имаме командата tarantoolctl, која ви овозможува да управувате со примерите на Tarantula. На пример, примерот за проверка на tarantoolctl ќе ја провери конфигурациската датотека и ќе каже - датотеката е во ред ако таму нема синтаксички грешки.

Можете да го видите статусот на примерот - пример за статус tarantoolctl. На ист начин можете да направите старт, стоп, рестарт.

Откако примерокот работи, можете да се поврзете со него на два начина.

1. Административна конзола

Стандардно, Tarantool отвора приклучок, таму се испраќа нормален ASCII текст за да го контролира Tarantool. Поврзувањето со конзолата секогаш се случува под административниот корисник, нема автентикација, така што нема потреба да се екстернализира пристаништето на конзолата за управување со Tarantula.

За да се поврзете користејќи го овој метод, треба да го внесете Tarantoolctl внесете го името на примерот. Командата ќе ја стартува конзолата и ќе се поврзе како администратор. Никогаш не ја изложувајте портата на конзолата нанадвор - подобро е да ја оставите како приклучок за единица. Тогаш само оние кои имаат пристап да пишуваат до штекерот ќе можат да се поврзат со Тарантула.

Овој метод е потребен за административни работи. За да работите со податоци, користете го вториот метод - бинарниот протокол.

2. Користење на бинарен протокол за поврзување со одредена порта

Конфигурацијата содржи директива за слушање, која отвора порта за надворешни комуникации. Оваа порта се користи со бинарниот протокол и таму е овозможена автентикација.

За оваа врска се користи tarantoolctl connect to број на порта. Користејќи го, можете да се поврзете со оддалечени сервери, да користите автентикација и да доделувате различни права за пристап.

Модул за снимање на податоци и кутија

Бидејќи Tarantool е и база на податоци и сервер за апликации, тој има различни модули. Ние сме заинтересирани за модулот кутија - тој спроведува работа со податоци. Кога пишувате нешто во кутија, Tarantool ги запишува податоците на дискот, ги складира во меморија или прави нешто друго со нив.

Рекорд

На пример, влегуваме во модулот box и ја повикуваме функцијата box.one. Ова ќе го принуди 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

По ова, создаваме примарен индекс - примарен - со кој можеме да бараме податоци. Стандардно, ако не наведете никакви параметри, првото поле во секој запис ќе се користи за примарниот индекс.

Потоа правиме грант на гостинот, под кој се поврзуваме преку бинарниот протокол. Дозволуваме читање, пишување и извршување низ целиот примерок.

Во споредба со конвенционалните бази на податоци, сè овде е прилично едноставно. Имаме простор - област во која нашите податоци се едноставно складирани. Секој запис се нарекува торка. Спакуван е во MessagePack. Ова е многу кул формат - тој е бинарен и зафаќа помалку простор - 18 бајти наспроти 27.

Сосема е погодно да се работи со него. Речиси секоја линија, секој запис со податоци може да има сосема различни колони.

Можеме да ги прегледаме сите празни места користејќи ја командата Box.space. За да изберете одреден пример, напишете пример box.space и добијте целосни информации за него.

Tarantool има два вградени мотори: Memory и Vinyl. Меморијата ги складира сите податоци во меморијата. Затоа, сè работи едноставно и брзо. Податоците се фрлаат на дискот, а има и механизам за евиденција за однапред запишување, така што нема да изгубиме ништо ако серверот падне.

Винил ги складира податоците на дискот во форма што ни е попозната - односно, можете да складирате повеќе податоци отколку што имаме меморија, а Тарантула ќе ги чита од дискот.

Засега ќе користиме Меморија.

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 квинтилиони. Тоа е многу.

Потоа можеме да вметнеме податоци користејќи ја командата за внесување.

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, што го опишав погоре.

Излез на податоци

Потоа можеме да ги прикажеме податоците користејќи ја командата изберете.

Box.example.select со копчето {1} ќе го прикаже саканиот запис. Ако го спуштиме клучот, ќе ги видиме сите записи што ги имаме. Сите тие се разликуваат по бројот на колони, но овде, во принцип, не постои концепт на колони - има броеви на полиња.

Може да има апсолутно секаква количина на податоци. И на пример, треба да ги бараме по второто поле. За да го направите ова, создаваме нов секундарен индекс.

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

Ја користиме командата Create_index.
Да го наречеме Секундарно.

По ова треба да ги наведете параметрите. Типот на индекс е ДРВО. Можеби не е единствен, затоа внесете Unique = false.

Потоа посочуваме од кои делови се состои нашиот индекс. Поле е бројот на полето за кое го врзуваме индексот и го одредуваме типот на стрингот. И така е создадено.

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 прави контролни точки и ги зачувува податоците на дискот, но ако престанеме да работиме до следното зачувување, ќе ги изгубиме сите операции - затоа што ќе се опоравиме од последната контролна точка, која беше, на пример, пред два часа.

Нема да работи ниту да се зачувува секоја секунда, бидејќи постојаното фрлање 20 GB на дискот не е добра идеја.

За таа цел, беше измислен и имплементиран концептот на дневник за однапред запишување. Со негова помош, за секоја промена на податоците, се креира запис во мала датотека за евиденција за однапред запишување.

Секој влез до контролниот пункт се чува во нив. За овие датотеки ја поставуваме големината - на пример, 64 MB. Кога е полна, снимањето започнува да оди во втората датотека. И по рестартирањето, 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()

Изјавуваме некоја табела во луа која ги дефинира знаците. Оваа плоча е потребна за да се генерира случаен стринг.

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')

По ова, започнуваме со портата 8080 на сите интерфејси на серверот http, кои ќе ги евидентираат сите барања и грешки.

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

Следно, ја декларираме рутата, така што ако пристигне барање со методот GET на портата 8080 /count, тогаш ја повикуваме функцијата од една линија. Го враќа статусот - 200, 404, 403 или кој било друг што ќе го наведеме.

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

Во телото враќаме json.encode, во него означуваме count и getcount, што се повикува и го покажува бројот на записи во нашата база на податоци.

Втор метод

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)

Каде во редот рутер: рута ({method = 'GET', патека = '/токен'}, функција() ја повикуваме функцијата и генерираме токен.

Линија локален токен = randomString(32) е случајна низа од 32 знаци.
Во линија локално последно = box.space.example:len() го вадиме последниот елемент.
И во линијата box.space.example:insert{ last + 1, token } ги запишуваме податоците во нашата база на податоци, односно едноставно го зголемуваме ID за 1. Тоа може да се направи, патем, не само на овој несмасен начин. За ова има секвенци во Тарантула.

Таму го пишуваме токенот.

Така, апликацијата ја напишавме во една датотека. Можете директно да манипулирате со податоците таму, а кутијата модул ќе ја заврши целата валкана работа наместо вас.

Слуша http и работи со податоци, се е во еден пример - и апликацијата и податоците. Затоа, сè се случува доста брзо.

За да започнеме, го инсталираме 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:/#

Ни треба и прометеј за да трчаме:

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 јадра и 4 гигабајти меморија.

Можете исто така да изберете околу 50000 токени и да ја видите неговата вредност.

Можете да користите не само http, туку и да извршувате функции во заднина што ги обработуваат вашите податоци. Плус има различни предизвикувачи. На пример, можете да повикате функции на ажурирања, да проверите нешто - исправете ги конфликтите.

Можете да пишувате апликации за скрипти директно во самиот сервер на базата на податоци, и да не бидете ограничени со ништо, да поврзете какви било модули и да имплементирате каква било логика.

Апликативниот сервер може да пристапи до надворешни сервери, да ги враќа податоците и да ги додава во својата база на податоци. Податоците од оваа база на податоци ќе се користат од други апликации.

Тарантулата сама ќе го направи тоа и нема да мора да пишувате посебна апликација.

Во заклучок

Ова е само првиот дел од едно големо дело. Вториот ќе биде објавен наскоро на блогот на Mail.ru Group, а ние дефинитивно ќе додадеме врска до него во овој материјал.

Ако сте заинтересирани да присуствувате на настани каде што ги градиме овие работи онлајн и да поставувате прашања во реално време, вклучите се канал DevOps од REBRAIN.

Ако треба да се преселите во облакот или имате прашања за вашата инфраструктура, слободно оставете барање.

П.С Имаме 2 бесплатни ревизии месечно, можеби вашиот проект ќе биде еден од нив.

Извор: www.habr.com