$ curl -L https://tarantool.io/installer.sh | sudo bash -s -- --repo-only
$ sudo yum install cartridge-cli

$ brew install cartridge-cli

$ cartridge create --name tarantool-demo
$ cd tarantool-demo
$ cartridge build

local admin_tasks = {}
local json = require('json')
local pool = require('cartridge.pool')
admin_tasks.cleanup = {
    -- описываем новую функцию
    usage = 'Clean old products from cache',
    -- конкретно cleanup не будет принимать аргументов.
    -- с форматом аргументов можно ознакомиться в примере на GitHub
    -- https://github.com/tarantool/cartridge-cli-extensions/blob/master/doc/admin.md#example
    args = nil,
    call = function(opts)
        opts = opts or {}
        local servers = {}
        local total = { products = 0 }
        -- функция для проверки имеет ли репликасет определённую роль
        local function replicaset_has_role(replicaset, role)
            for _, name in ipairs(replicaset.roles) do
                if name == role then
                    return true
                end
            end
            return false
        end
        -- обходим все сервера в кластере и выбираем только те, которые:
        -- 1) имеют роль vshard-storage
        -- 2) являются мастером в своем репликасете
    for _, rs in pairs(cartridge.admin_get_replicasets()) do
            if replicaset_has_role(rs, 'vshard-storage') then
                local server = rs.active_master
                if server ~= nil and server ~= "expelled" then
                    if server.status == 'unreachable' then
                        return nil, ("Server %s status is %s"):format(server.alias, server.status)
                    else
                        servers[server.alias] = server.uri
                    end
                end
            end
        end
        -- выполняем очистку данных по очереди на каждом из стораджей
        for alias, uri in pairs(servers) do
            -- префикс можно задать любой, например добавить порядковый номер сервера
            local prefix = alias
            local conn, err = pool.connect(uri)
            if err ~= nil then
                print(("Cleanup [%s]: error %s"):format(prefix, err))
            else
                -- собственно вызов функции
                -- здесь есть небольшой хак, создадим таблицы прямо из admin функции
                -- на реальном примере таблица должна существовать изначально
                local res = conn:eval([[
                    box.schema.create_space('products', { if_not_exists = true })
                    box.space.products:create_index('primary', { if_not_exists = true })
                    local len = box.space.products:len()
                    box.space.products:truncate()
                    return { products = len }
                ]])
                -- выводим промежуточный результат в консоль
                print(("Cleanup [%s]: deleted %s"):format(prefix, json.encode(res)))
                total.products = total.products + res.products
            end
        end
        return ("Deleted total %s"):format(json.encode(total))
    end
}

-- инициализация модуля admin
local cli_admin = require('cartridge-cli-extensions.admin')
cli_admin.init()
-- регистрируем все функции таблицы admin_tasks из примера выше
for name, task in pairs(admin_tasks) do
    local ok, err = cli_admin.register(name, task.usage, task.args, task.call)
    if ok ~= true then
        error(err)
    end
end

box.schema.create_space('products', { if_not_exists = true })
box.space.products:create_index('primary', { if_not_exists = true })

⨯ Failed to call "cleanup": eval:1: attempt to index field 'products' (a nil value)

$ cartridge start -d
$ cartridge replicasets setup

./cartridge admin \
  --name tarantool-demo \
  --run-dir ./tmp/run \
  --instance router \
  --list