ECSS-10, версия 3.11
Быстрые ссылки
Дерево страниц
Перейти к концу метаданных
Переход к началу метаданных

В данном разделе представлены команды управления кластерами с ролью BUS.

<NODE> - имя ноды.
<CLUSTER> - имя кластера с ролью BUS.

delete

Команда удаления AMQP-объекта с брокера.

Путь команды:

/cluster/bus/<NODE@CLUSTER>/delete

Синтаксис:

delete <OBJECT> where <WHERE_CONDITION>

Параметры:

<OBJECT> - AMQP-объект;
<WHERE_CONDITION> - условие отбора удаляемой записи.

Пример:

ecss-root@[mycelium1@leonid1]:/# cluster/bus/mycelium1/delete queue where name = cowboy_client2.10.0.ecss-10-system.rps.c
[delete] 
         You are going to delete 13 object(s) forever.
         You can corrupt broker data and interrupt active calls.

         THINK TWICE

         Selected objects:
           cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.ds1.q
           cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.tts1.tts1@leonid1.q
           cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.ds1.ds1@leonid1.q
           cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.md1.q
           cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.core1.core1@leonid1
         .q
           cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.pa_sip1.pa_sip1@leo
         nid1.q
           cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.tts1.q
           cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.mycelium-mycelium1.
         q
           cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.pa_sip1.q
           cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.md1.md1@leonid1.q
           cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.core1.q
           cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.mycelium-mycelium1.
         mycelium1@leonid1.q
           cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.q

Are you sure?: [n]/y ?> y

list

Команда просмотра списка AMQP-объектов на брокере.

Путь команды:

/cluster/bus/<NODE@CLUSTER>/list

Синтаксис:

list [<OBJECT>]

Параметры:

<OBJECT> - AMQP-объект.

Пример:

ecss-root@[mycelium1@leonid1]:/# cluster/bus/mycelium1/list
-----------------------
|#|   Object   |Number|
|-+------------+------|
|1|Session     |111   |
|2|Queue       |120   |
|3|Subscription|174   |
|4|Exchange    |16    |
|5|Binding     |313   |
|6|Connections |30    |
|7|Nodes       |1     |
-----------------------

ping

Команда измерения латентности взаимодействия с AMQP-брокером.

Путь команды:

/cluster/bus/<NODE@CLUSTER>/ping

Синтаксис:

ping [<TestNum> [<Timeout>]]

Параметры:

<TestNum> - количество ping-запросов;
<Timeout> - время между отправкой повторных ping-запросов.

Пример:

ecss-root@[mycelium1@leonid1]:/# cluster/bus/mycelium1/ping
total=1112 net=921 route=8 qu=46 session=137
total=893 net=714 route=7 qu=31 session=141
total=1111 net=910 route=8 qu=26 session=167
total=1141 net=958 route=58 qu=27 session=98
total=973 net=774 route=8 qu=54 session=137

--- ping statistics ---
5 messages transmitted, 5 messages received, 0 messages loss
avarage: total=1046 net=855 route=17 qu=36 session=136

reset_stat

Команда для сброса статистики AMQP-объекта на брокере.

Путь команды:

/cluster/bus/<NODE@CLUSTER>/reset_stat

Синтаксис:

reset_stat <QUEUE> where <WHERE_CONDITION>

Параметры:

<QUEUE> - имя очереди;
<WHERE_CONDITION> - условия отбора записи.

Пример:

support@[mycelium1@biysk1]:/$ cluster/bus/mycelium1@biysk1/reset_stat queue where depth > 3

show

Команда просмотра параметров AMQP-объекта на брокере.

Путь команды:

/cluster/bus/<NODE@CLUSTER>/show

Синтаксис:

show message <Qu> <MsgId> - просмотр информации об определенном сообщении в очереди
show rejected <Node>/<MsgId> - просмотр информации об определенном сообщении, которое было отклонено
show queue <Qu> - просмотр информации об определенной очереди

Параметры:

<Qu> - очередь AMQP;
<MsgId> - идентификатор сообщения;
<Node> - имя ноды.

Пример:

Информация об очереди:

/cluster/bus/ecss_mycelium@ubs64/show queue ecss.rps.apf.q
Name                   ecss.rps.apf.q
Alternate exchange     -
Durable                yes
Exclusive              no
Auto delete            no
Pid                    <0.305.0>
Uptime                 4d 03:11:18
Subscription number    0
Depth                  480
Messages in/out        31099/30619
Max depth              1001
drop_num               12307
Lifetime interval (ms) 
GC period (ms)         never
Maximum possible depth undefined
drop_type              drop arrived message
Warning on overlow     yes
shuffle_subs           no


  • Нет меток