← Back
Editing: asgi.cpython-312.pyc
� ���gF � �R � d dl mZ d dlmZ ddlmZ ddlmZmZ edfdede d efd �Z y ) � )�Callable)�parse_qs� )� _bake_output)�CollectorRegistry�REGISTRYF�registry�disable_compression�returnc � � �� �� fd�}|S )z;Create a ASGI app which serves the metrics from a registry.c � �j �K � | j d� dk( sJ �t | j dd� � }dj | j d� D ��cg c]8 \ }}|j d� j � dk( r|j d� ��: c}}� }dj | j d� D ��cg c]8 \ }}|j d� j � d k( r|j d� ��: c}}� }t �|||�� \ }} } g } | D ]# } | j t d � | D � � � �% |� � d { ��� } | j d� d k( rC |d t |j d � d � | d�� � d { ��� |d| d�� � d { ��� y y c c}}w c c}}w 7 �h7 �'7 ��w)N�type�http� query_string� �,�headers�utf8�acceptzaccept-encodingc 3 �> K � | ] }|j d � �� � y�w)r N)�encode)�.0�xs �E/opt/hc_python/lib/python3.12/site-packages/prometheus_client/asgi.py� <genexpr>z8make_asgi_app.<locals>.prometheus_app.<locals>.<genexpr> s � �� �*L�V��1�8�8�F�+;�V�s � z http.requestzhttp.response.start� r )r �statusr zhttp.response.body)r �body) �getr �join�decode�lowerr �append�tuple�int�split)�scope�receive�send�params�name�value� accept_header�accept_encoding_headerr r �output�formatted_headers�header�payloadr r s ��r �prometheus_appz%make_asgi_app.<locals>.prometheus_app s� �� �� ��y�y�� �F�*�*�*��%�)�)�N�C�8�9�����6;�i�i� �6J�" �6J�]�d�E��{�{�6�"�(�(�*�h�6� �L�L�� �6J�" � � � "%���6;�i�i� �6J�+ �6J�]�d�E��{�{�6�"�(�(�*�.?�?� �L�L�� �6J�+ � " � � #/�x� �H^�`f�h{�"|� ���� �� �F� � $� $�U�*L�V�*L�%L� M� � � �/�� �;�;�v� �.� 0�� 1� !�&�,�,�s�"3�A�"6� 7� 0��� � � � 4�f�E�F� F� F� 1�� " ��+ � "�� �� G�sP �AF3�=F! �'F3�8=F' �5AF3�F-�AF3�F/�F3�F1�F3�/F3�1F3� )r r r3 s `` r � make_asgi_appr5 s �� �G�: �r N) �typingr � urllib.parser � expositionr r r r �boolr5 r4 r r �<module>r: s5 �� � !� $� 1� 19�V[� � -� �t� �`h� r
Save File
Cancel