�
l0&i� � �\ � d Z ddlZddlZd� Zd� Zd� Zedk( r ej eg� yy)z:Tests for Python OpenTelemetry SDK metric exporter adapter� Nc � � ddl } t j � 5 }| j |d�� }|j � }|�J d� �t |d� sJ d� �t |d� sJ d � �t |d
� sJ d � �t |d � sJ d
� �|j
� }|�J d� �|j d�� }|�J d� �|j � }|�J d� �|j
� ddd� y# 1 sw Y yxY w)z?Test that metric exporter adapter implements required interfacer N� ��
output_dir�write_interval_secsz1metric_exporter_adapter() should return an object�exportz#Adapter should have export() method�shutdownz%Adapter should have shutdown() method� force_flushz(Adapter should have force_flush() method� temporalityz(Adapter should have temporality() methodz shutdown() should return None�� ��timeout_millisz$force_flush() should return a resultz#temporality() should return a value) �otlp_arrow_library�tempfile�TemporaryDirectory�
PyOtlpLibrary�metric_exporter_adapter�hasattrr r
r )r �tmpdir�library�metric_exporter�result� flush_resultr s �%tests/python/test_adapters_metrics.py� test_metric_exporter_interfacer s- � � � � $� $� &�&�$�2�2� � !� 3�
�� "�9�9�;�� �*�_�,_�_�*� ���1�X�3X�X�1���
�3�\�5\�\�3���
�6�b�8b�b�6���
�6�b�8b�b�6� !�)�)�+���~�>� >�>�~� '�2�2�$�2�G� ��'�O�)O�O�'� &�1�1�3� ��&�M�(M�M�&� ����;
'� &� &�s �CC8�8Dc � � ddl } ddlm} ddlm} ddlm} t j � 5 }| j |d�� }|j � } |d �
� } |g� � }j |� |j t � } | j# d d
d�� }
|
j% dddd�� |
j% dddd�� |j' d�� |j) � |j) � ddd� y# t $ r t j d� Y ��w xY w# |j) � |j) � w xY w# 1 sw Y yxY w)z>Test metric exporter with actual OpenTelemetry SDK metric datar N��
MeterProvider�� PeriodicExportingMetricReader��metrics�_OpenTelemetry SDK not installed - install with: pip install opentelemetry-api opentelemetry-sdkr r �d ��export_interval_millis��metric_readers� test_counterzA test counter metric�1)� description�unit� �testz test-service)� environment�service� r r
)r �opentelemetry.sdk.metricsr � opentelemetry.sdk.metrics.exportr �
opentelemetryr" � ImportError�pytest�skipr r r r �set_meter_provider� get_meter�__name__�create_counter�addr
r ) r r r r" r r r �reader�meter_provider�meter�counters r �'test_metric_exporter_with_real_sdk_datarA + s[ � � �w�;�R�)�
� $� $� &�&�$�2�2� � !� 3�
�� "�9�9�;�� /� �#&�
�� '�v�h�?�� �"�"�>�2� ��%�%�h�/�E��*�*� � 3�� +� �G�
�K�K��6�n�M� N� �K�K��6�n�M� N�
� &� &�d� &� ;�
�
� #� #� %� � � � �[
'� &�� � w�� � �u�v�w��^
� #� #� %� � � � ��[
'� &�s6 �D �A E�6A%D+� E� D(�'D(�+"E
�
E�Ec �� � ddl } ddlm} ddlm} ddlm} t j � 5 }| j |d�� }|j � } |d �
� } |g� � }j |� |j t � } | j# d d
�� }
| j% dd�� } |
j' d� | j' d� |j) � |j+ d�� } | sJ d� � |j- � |j- � ddd� y# t $ r t j d� Y ��2w xY w# |j- � |j- � w xY w# 1 sw Y yxY w)zGTest metric exporter by directly calling export with SDK-generated datar Nr r r! r# r r r$ r% r' r) z Test counter)r+ �
test_gaugez
Test gauge�
r- r r
zForce flush should succeed)r r2 r r3 r r4 r" r5 r6 r7 r r r r r8 r9 r: r; �create_up_down_counterr< �collectr
r )
r r r r" r r r r= r> r? r@ �gauger s
r �"test_metric_exporter_direct_exportrH g sl � � �w�;�R�)�
� $� $� &�&�$�2�2� � !� 3�
�� "�9�9�;�� /� �#&�
�� '�v�h�?���"�"�>�2� ��%�%�h�/�E��*�*�>�~�*�V�G��0�0� �<�0�X�E�
�K�K��O� �I�I�a�L�
�N�N� � $�/�/�t�/�D�F�� 7�7� 7�6�
� #� #� %� � � � �O
'� &�� � w�� � �u�v�w��R
� #� #� %� � � � ��O
'� &�s6 �D) �A E3�6BE�? E3�) E �
E �"E0�0E3�3E<�__main__) �__doc__r r6 r rA rH r: �main�__file__� � r �<module>rO s? �� @� �
�!�H9 �x3 �l �z���F�K�K��
�� rN