Results / mqttium
mqttium 1.1.0 asyncio
| version | 1.1.0 |
|---|---|
| I/O model | asyncio |
| implementation | python |
| stability | stable |
| completion | callback |
| drive shape | nowait |
| Python | 3.12.13 |
Private API the adapter depends on
PublishReceipt._waiters / PublishReceipt._error: 1.0.0rc15 removed on_publish. QoS>=1 completion is observed by registering one future on the receipt, which is what PublishReceipt.wait does, and reading _error when it resolves. A Task per publish would be a harness tax rc14 does not pay.
Every point
| point | headline | value | CPU / msg | peak RSS | flags |
|---|---|---|---|---|---|
| pub_qos0_max | msgs/s | 77,947 | 12.9 µs | 28.0 MiB | broker bound |
| pub_qos1_max | msgs/s | 26,875 | 37.2 µs | 26.5 MiB | |
| pub_qos1_fixed | p50 | 143 µs | 148 µs | 26.7 MiB | |
| sub_qos0_max | msgs/s | 70,784 | 14.1 µs | 26.5 MiB | offer bound |
| sub_qos1_fixed | p50 | 168 µs | 93.8 µs | 26.6 MiB | |
| rtt_qos1_fixed | p50 | 270 µs | 264 µs | 26.6 MiB | |
| pub_16k_fixed | p50 | 143 µs | 194 µs | 26.7 MiB | |
| idle_connect | connect | 1.2 ms | 26.3 MiB | ||
| pub_qos1_fixed_v5 | p50 | 152 µs | 149 µs | 26.6 MiB | |
| sub_qos1_fixed_v5 | p50 | 168 µs | 96.9 µs | 26.6 MiB | |
| rtt_qos1_fixed_v5 | p50 | 270 µs | 266 µs | 26.7 MiB | |
| sub_qos1_max | msgs/s | 49,475 | 20.2 µs | 26.7 MiB | broker boundoffer bound |
| pub_qos1_max_v5 | msgs/s | 26,525 | 37.7 µs | 26.5 MiB | |
| sub_qos1_max_v5 | msgs/s | 48,179 | 20.8 µs | 26.6 MiB | broker boundoffer bound |
| pub_qos1_max_16k | msgs/s | 22,536 | 44.4 µs | 27.5 MiB | broker bound |
| pub_qos1_fixed_500 | p50 | 160 µs | 265 µs | 26.5 MiB | |
| pub_qos1_fixed_5k | p50 | 233 µs | 92.3 µs | 26.9 MiB | |
| sub_qos1_fixed_500 | p50 | 258 µs | 158 µs | 26.4 MiB | |
| sub_qos1_fixed_5k | p50 | 152 µs | 83.3 µs | 26.9 MiB | |
| rtt_qos0_fixed | p50 | 242 µs | 154 µs | 26.7 MiB | |
| pub_qos2_max | msgs/s | 19,429 | 51.4 µs | 26.6 MiB | |
| pub_qos2_fixed | p50 | 303 µs | 186 µs | 26.6 MiB | |
| sub_qos2_fixed | p50 | 184 µs | 166 µs | 26.6 MiB | |
| pub_fanout_fixed | p50 | 152 µs | 148 µs | 26.8 MiB | |
| sub_fanin_fixed | p50 | 160 µs | 95.0 µs | 26.7 MiB | |
| sub_filters_fixed | p50 | 217 µs | 159 µs | 26.8 MiB | |
| duplex_qos1_fixed | p50 | 92.2 µs | 119 µs | 26.7 MiB | |
| pub_qos1_fixed_tls | p50 | 176 µs | 173 µs | 30.1 MiB | |
| sub_qos1_fixed_tls | p50 | 193 µs | 126 µs | 30.2 MiB | |
| idle_connect_tls | connect | 7.3 ms | 29.9 MiB | ||
| pub_qos1_fixed_v5_props | p50 | 152 µs | 152 µs | 26.7 MiB | |
| sub_qos1_fixed_v5_props | p50 | 176 µs | 116 µs | 26.8 MiB | |
| pub_qos1_fixed_v5_alias | p50 | 152 µs | 153 µs | 26.7 MiB | |
| sub_qos1_max_v5_rm16 | msgs/s | 31,609 | 30.3 µs | 26.5 MiB | broker boundbroker queue overflow |
| pub_64k_fixed | p50 | 336 µs | 290 µs | 26.9 MiB | |
| pub_1m_fixed | p50 | 1,999 µs | 1,980 µs | 29.4 MiB | |
| pub_rl_boundaries | p50 | 217 µs | 1,646 µs | 34.4 MiB |