Можете ли вы помочь мне найти продолжительность сообщений в очереди. То есть как долго сообщения находятся в очереди без использования. С моим кодом я могу найти количество сообщений в очереди.
Мой код:
request = urllib.request.Request("http://localhost:15672/api/queues");
base64string = base64.encodebytes(('%s:%s' % ('xxx', 'xxx')).encode()).decode().strip()
request.add_header("Authorization", "Basic %s" % base64string);
data = json.load(urllib.request.urlopen(request));
return data;
Результат кода:
{'arguments': {}, 'auto_delete': False, 'backing_queue_status': {'avg_ack_egress_rate': 0.0,
'avg_ack_ingress_rate': 0.0, 'avg_egress_rate': 0.0, 'avg_ingress_rate': 0.0, 'delta': ['delta',
'undefined', 0, 0, 'undefined'], 'len': 1, 'mode': 'default', 'next_seq_id': 1, 'q1': 0, 'q2': 0, 'q3':
0, 'q4': 1, 'target_ram_count': 'infinity'}, 'consumer_utilisation': None, 'consumers': 0, 'durable':
True, 'effective_policy_definition': [], 'exclusive': False, 'exclusive_consumer_tag': None,
'garbage_collection': {'fullsweep_after': 65535, 'max_heap_size': 0, 'min_bin_vheap_size': 46422,
'min_heap_size': 233, 'minor_gcs': 1}, 'head_message_timestamp': None, 'idle_since': '2020-04-17
7:33:26', 'memory': 18452, 'message_bytes': 32, 'message_bytes_paged_out': 0, 'message_bytes_persistent':
32, 'message_bytes_ram': 32, 'message_bytes_ready': 32, 'message_bytes_unacknowledged': 0, 'messages': 1,
'messages_details': {'rate': 0.0}, 'messages_paged_out': 0, 'messages_persistent': 1, 'messages_ram': 1,
'messages_ready': 1, 'messages_ready_details': {'rate': 0.0}, 'messages_ready_ram': 1,
'messages_unacknowledged': 0, 'messages_unacknowledged_details': {'rate': 0.0},
'messages_unacknowledged_ram': 0, 'name': 'test_monitor', 'node': 'rabbit@morsetmfhs16q',
'operator_policy': None, 'policy': None, 'recoverable_slaves': None, 'reductions': 36895,
'reductions_details': {'rate': 0.0}, 'state': 'running', 'vhost': '/'}
Спасибо .