File: //usr/lib/python3.6/site-packages/cloudinit/sources/azure/__pycache__/kvp.cpython-36.opt-1.pyc
3
\�meX � @ s� d dl Z d dlmZ d dlmZ d dlmZ d dlmZmZ d dl m
Z
m Z e j e
�Zeej d�dd �Zeed
�d d �Ze
jed
�dd�Zed�dd�ZdS )� N)�datetime)�Optional)�version)�handlers� instantiated_handler_registry)�errors�identity)�returnc C s t jjd�} t| tj�s dS | S )z'Get instantiated KVP telemetry handler.Z telemetryN)r Zregistered_items�get�
isinstancer �HyperVKvpReportingHandler)� kvp_handler� r �/usr/lib/python3.6/kvp.py�get_kvp_handler s
r )�reportr c C s, t � }|dkr tjd� dS |jd| � dS )z/Report to host via PROVISIONING_REPORT KVP key.Nz.KVP handler not enabled, skipping host report.FZPROVISIONING_REPORTT)r �LOG�debugZ write_key)r r
r r r �report_via_kvp s
r )�errorr c C s t | j� �S )N)r Zas_encoded_report)r r r r �report_failure_to_host& s r c C sr y t j� } W n, tk
r8 } zd|��} W Y d d }~X nX tjddtj� � �dtj� j � � �d| � �g�}t
|�S )Nzfailed to read vm id: zresult=successzagent=Cloud-Init/z
timestamp=zvm_id=) r Z query_vm_id� Exceptionr Z
encode_reportr Zversion_stringr ZutcnowZ isoformatr )Zvm_idZid_errorr r r r �report_success_to_host* s r )Zloggingr Ztypingr Z cloudinitr Zcloudinit.reportingr r Zcloudinit.sources.azurer r Z getLogger�__name__r r r �str�boolr ZReportableErrorr r r r r r �<module> s