В этом разделе описаны команды для просмотра ресурсов транспортной подсистемой определенного вычислительного узла.

list connection

Команда для просмотра списка всех соединений AMQP вычислительного узла с именем <some_node>.
Записи в таблице могут быть упорядочены по любому из параметров по убыванию или возрастанию, ограничены по количеству выводимых строк.

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

/node/<mycelium_node>/mycelium_client/list connection

Синтаксис:

list <connection|session> [where <condition> <operator> <value>, [<condition>...]] [order by <column> [asc|desc]] [last|first <N>]

Параметры:

[where <condition>] - при указании команды "where" задается условие отбора записей в таблице:
<condition> - условие отбора записей, задается в виде <condition> <operator> <value> [, <condition>], где

<condition> - условие, по которому производится отбор, принимает значения:

broker - адрес amqp10 брокера в формате IP-адрес:номер порта;
con_name - имя соединения;
drop_msg - количество отброшенных сообщений;
heartbeat_timeout - период посылки heartbeat-сообщений (в секундах);
state - состояние соединения;

<operator> - оператор, принимает значения: /= < = =< > >=;<value> - значение, по которому совершается отбор.

[order by <column> [asc|desc]] [last|first <N>] - при указании команды "order by" задается условие сортировки записей в таблице

<column> - название колонки, по которой будет сортировка записей, принимает значения:

avg_load_in_out - средняя нагрузка в сообщениях в секунду на вход/на выход;
broker - адрес amqp10 брокера в формате IP-адрес:номер порта;
channels_cur - текущее количество занятых каналов;
channels_max - максимальное количество занятых каналов;
cmd_in_out - количество полученных / отправленных команд;
con_name - имя соединения;
drop_msg - количество отброшенных сообщений;
heartbeat_timeout - период посылки heartbeat-сообщений (в секундах);
state - состояние соединения;
uptime - время, в течение которого система функционирует в рабочем режиме.

[asc|desc] - способ сортировки:

asc - по возрастанию;
desc - по убыванию.

[last|first <N>] - ограничение по количеству выводимых строк:

last - выводить последние N-строк таблицы;
first - выводить первые N-строк таблицы;
<N> - количество строк.

Пример:

Просмотреть список соединений AMQP брокера с адресом 192.168.1,21

admin@[mycelium1@ecss1]:/$ node/ds1@ecss1/mycelium_client/list connection where broker = 192.168.1.21                         
┌─┬──────────┬─────────┬────┬─────────────┬─────────────┬──────────────┬───────┬───────┬─────────────┬─────────────────┬────────┬──────┬───────────┐
│#│   Pid    │ Status  │ HT │  CmdIn/Out  │AvgLoadIn/Out│TrafficIn/Out │ChanCur│ChanMax│    Name     │     Broker      │Priority│Droped│  Uptime   │
├─┼──────────┼─────────┼────┼─────────────┼─────────────┼──────────────┼───────┼───────┼─────────────┼─────────────────┼────────┼──────┼───────────┤
│1│<0.2497.0>│connected│2000│0/18         │0.0/0.0      │94.52K/94.12K │2/8192 │2/8192 │geo_backup_l1│192.168.1.21:5672│9       │0     │0d 13:23:17│
│2│<0.2492.0>│connected│2000│5170/10522   │0.107/0.218  │443.94K/94.12K│2/8192 │2/8192 │cocon_l1     │192.168.1.21:5672│9       │0     │0d 13:23:17│
│3│<0.2487.0>│connected│200 │106226/159612│2.203/3.311  │5.05M/941.11K │1/8192 │1/8192 │tring_l1     │192.168.1.21:5672│9       │0     │0d 13:23:17│
│4│<0.2482.0>│connected│2000│12897/58769  │0.267/1.219  │920.61K/94.12K│1/8192 │1/8192 │rps_l2       │192.168.1.21:5672│9       │0     │0d 13:23:17│
│5│<0.2481.0>│connected│2000│0/0          │0.0/0.0      │94.08K/94.12K │0/8192 │0/8192 │rps_l1       │192.168.1.21:5672│9       │0     │0d 13:23:17│
│6│<0.2475.0>│connected│2000│1262/3766    │0.026/0.078  │210.68K/94.12K│5/8192 │5/8192 │ds_l4        │192.168.1.21:5672│9       │0     │0d 13:23:17│
│7│<0.2474.0>│connected│2000│871/2702     │0.018/0.056  │193.01K/94.12K│4/8192 │4/8192 │ds_l3        │192.168.1.21:5672│9       │0     │0d 13:23:17│
│8│<0.2473.0>│connected│2000│1266/3772    │0.026/0.078  │233.38K/94.12K│4/8192 │4/8192 │ds_l2        │192.168.1.21:5672│9       │0     │0d 13:23:17│
│9│<0.2472.0>│connected│2000│845/2511     │0.017/0.052  │184.29K/94.12K│4/8192 │4/8192 │ds_l1        │192.168.1.21:5672│9       │0     │0d 13:23:17│
└─┴──────────┴─────────┴────┴─────────────┴─────────────┴──────────────┴───────┴───────┴─────────────┴─────────────────┴────────┴──────┴───────────┘
Pid              - connection pid
State            - connection state (idle | connecting | connected | closing | closed)
HT               - heartbeat timer
CmdIn/Out        - incoming command / outcoming command
TrafficIn/Out    - incoming traffic / outcoming traffic (only local traffic*)
ChanCur          - count used channels / possible maximum
ChanMax          - count max channels / possible maximum
Node             - connection node
From             - connection from pid
Uptime           - elapsed time since the launch

[exec at: 12.02.2019 22:28:57, exec time: 83ms, nodes: ds1@ecss1]

list session

Команда для просмотра списка всех сессий AMQP вычислительного узла с именем <some_node>.
Записи в таблице могут быть упорядочены по любому из параметров по убыванию или возрастанию, ограничены по количеству выводимых строк.

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

/node/<NODE>/mycelium_client/list session

Синтаксис:

list session [where <condition>] [order by <column> [asc|desc]] [last|first <N>]

Параметры:

[where <condition>] - при указании команды "where" задается условие отбора записей в таблице:
<condition> - условие отбора записей, задается в виде <сolumn> <operator> <value> [, <condition>], где

<condition> может принмать значения

con_name
session_name
state

<column> - название колонки, по которой производится отбор, принимает значения:

cmd_in_out - количество полученных / отправленных команд;
con_name - имя соединения в формате (connection_name@ream_name);
cur_queues - текущее состояние очередей;
max_queues - пиковые значения для очередей;
disconnect_num - количество разъединений в сессии;
disconnected_time_max - максимальный промежуток времени, когда сессия была в состоянии "disconnected";
no_con_num - количество смен соединений в сессии (без разрыва связи);
session_name - имя сессии;
state - состояние сессии;
uptime - время, в течение которого система функционирует в рабочем режиме.

<operator> - оператор, принимает значения: /= < = =< > >=;

<value> - значение, по которому совершается отбор.

[order by <column> [asc|desc]] [last|first <N>] - при указании команды "order by" задается условие сортировки записей в таблице:

<column> - название колонки, по которой будет сортировка записей (описание см. выше).

[asc|desc] - способ сортировки:

asc - по возрастанию;
desc - по убыванию.

[last|first <N>] - ограничение по количеству выводимых строк:

last - выводить последние N-строк таблицы;
first - выводить первые N-строк таблицы;
<N> - количество строк.

Пример:

admin@[mycelium1@ecss1]:/$ node/ds1@ecss1/mycelium_client/list session where state = connected order by con_name first 5      
┌─┬───────────────────────────────────┬──────────┬─────────┬────────────────────┬──────────┬─────┬─────┬──────────┬───────┬───────────┐
│#│               Name                │   Pid    │  State  │     Con@Realm      │CmdIn/Out │MaxQ │CurQ │Disc/NoCon│DiscMax│  Uptime   │
├─┼───────────────────────────────────┼──────────┼─────────┼────────────────────┼──────────┼─────┼─────┼──────────┼───────┼───────────┤
│1│ecss.lock.manage...080-4a5753000000│<0.2527.0>│connected│cocon_l1@cocon_realm│76/169    │0/0/0│0/0/0│0/0       │22     │0d 13:33:52│
│2│ccn.node.ds1.ecss1                 │<0.2529.0>│connected│cocon_l1@cocon_realm│5210/10558│0/0/0│0/0/0│0/0       │22     │0d 13:33:52│
│3│ts_server#ds1@ec...060-138a19000000│<0.3136.0>│connected│ds_l1@ds_realm      │0/1       │0/0/0│0/0/0│0/0       │7      │0d 13:33:49│
│4│rtop-core-server#4#ds1@ecss1       │<0.3233.0>│connected│ds_l1@ds_realm      │412/1249  │0/0/0│0/0/0│0/0       │22     │0d 13:33:49│
│5│dds.bus.2.ds1.ecss1                │<0.3436.0>│connected│ds_l1@ds_realm      │0/7       │0/0/0│0/0/0│0/0       │6      │0d 13:33:49│
└─┴───────────────────────────────────┴──────────┴─────────┴────────────────────┴──────────┴─────┴─────┴──────────┴───────┴───────────┘

Pid       = session pid
CmdIn/Out = Total number of amqp commands sent(received) by session
CurQ      = Current state of queue lengths (see Queues)
MaxQ      = Max values of queue lengths (see Queues)
Queues    = "Unconfirmed" queue length / "Not sent" queue length / "Call waiters" dict length
NoCon     = Number of connection replacements on session (without user disconnect)
Disc      = Number of disconnects on session
DiscMax   = Max period of time when session was disconnected (including initial establishment time), in milliseconds

[exec at: 12.02.2019 22:39:34, exec time: 75ms, nodes: ds1@ecss1]