Results / amqtt
amqtt 0.12.1 asyncio
| version | 0.12.1 |
|---|---|
| I/O model | asyncio |
| implementation | python |
| stability | stable |
| completion | awaited |
| drive shape | awaited |
| Python | 3.12.13 |
Private API the adapter depends on
MQTTClient.session.delivered_message_queue: deliver_message() spawns a Task per wait and collapses to tens of msg/s under emqtt-bench ingress; the queue is the only path that sustains thousands of msg/s
Refused
Declared unsupported by the adapter, never approximated.
- pub_qos1_fixed_v5: not_implemented:mqtt_v5
- sub_qos1_fixed_v5: not_implemented:mqtt_v5
- rtt_qos1_fixed_v5: not_implemented:mqtt_v5
- pub_qos1_max_v5: not_implemented:mqtt_v5
- sub_qos1_max_v5: not_implemented:mqtt_v5
- sub_filters_fixed: not_implemented:native_message_callback_add
- pub_qos1_fixed_v5_props: not_implemented:mqtt_v5, not_implemented:v5_publish_properties
- sub_qos1_fixed_v5_props: not_implemented:mqtt_v5
- pub_qos1_fixed_v5_alias: not_implemented:mqtt_v5, not_implemented:v5_topic_alias
- sub_qos1_max_v5_rm16: not_implemented:mqtt_v5, not_implemented:v5_receive_maximum
Every point
| point | headline | value | CPU / msg | peak RSS | flags |
|---|---|---|---|---|---|
| pub_qos0_max | msgs/s | 11,876 | 85.7 µs | 279.7 MiB | |
| pub_qos1_max | msgs/s | 8,779 | 114 µs | 29.3 MiB | |
| pub_qos1_fixed | p50 | 96.3 µs | 294 µs | 29.3 MiB | |
| sub_qos0_max | msgs/s | 16,384 | 61.0 µs | 32.8 MiB | |
| sub_qos1_fixed | p50 | 258 µs | 213 µs | 29.0 MiB | |
| rtt_qos1_fixed | p50 | 770 µs | 636 µs | 29.4 MiB | |
| pub_16k_fixed | p50 | 135 µs | 554 µs | 29.3 MiB | |
| idle_connect | connect | 1.3 ms | 28.6 MiB | ||
| pub_qos1_fixed_v5 | p50 | unsupported | |||
| sub_qos1_fixed_v5 | p50 | unsupported | |||
| rtt_qos1_fixed_v5 | p50 | unsupported | |||
| sub_qos1_max | msgs/s | 8,932 | 112 µs | 33.5 MiB | broker boundbroker queue overflow |
| pub_qos1_max_v5 | msgs/s | unsupported | |||
| sub_qos1_max_v5 | msgs/s | unsupported | |||
| pub_qos1_max_16k | msgs/s | 8,345 | 120 µs | 29.3 MiB | |
| pub_qos1_fixed_500 | p50 | 143 µs | 770 µs | 29.2 MiB | |
| pub_qos1_fixed_5k | p50 | 67.6 µs | 200 µs | 29.7 MiB | |
| sub_qos1_fixed_500 | p50 | 369 µs | 302 µs | 28.9 MiB | |
| sub_qos1_fixed_5k | p50 | 217 µs | 160 µs | 29.5 MiB | |
| rtt_qos0_fixed | p50 | 639 µs | 496 µs | 29.3 MiB | |
| pub_qos2_max | msgs/s | 4,824 | 207 µs | 29.3 MiB | |
| pub_qos2_fixed | p50 | 639 µs | 477 µs | 29.4 MiB | |
| sub_qos2_fixed | p50 | 418 µs | 359 µs | 29.0 MiB | |
| pub_fanout_fixed | p50 | 100 µs | 299 µs | 29.4 MiB | |
| sub_fanin_fixed | p50 | 270 µs | 212 µs | 29.1 MiB | |
| sub_filters_fixed | p50 | unsupported | |||
| duplex_qos1_fixed | p50 | 92.2 µs | 389 µs | 29.4 MiB | |
| pub_qos1_fixed_tls | p50 | 113 µs | 317 µs | 32.8 MiB | |
| sub_qos1_fixed_tls | p50 | 287 µs | 214 µs | 32.5 MiB | |
| idle_connect_tls | connect | 7.4 ms | 32.2 MiB | ||
| pub_qos1_fixed_v5_props | p50 | unsupported | |||
| sub_qos1_fixed_v5_props | p50 | unsupported | |||
| pub_qos1_fixed_v5_alias | p50 | unsupported | |||
| sub_qos1_max_v5_rm16 | msgs/s | unsupported | |||
| pub_64k_fixed | p50 | 287 µs | 805 µs | 29.4 MiB | |
| pub_1m_fixed | p50 | 2,064 µs | 2,925 µs | 32.1 MiB | |
| pub_rl_boundaries | p50 | 258 µs | 2,998 µs | 39.0 MiB |