i#UddlmZddlZddlmZddlmZddlmZmZm Z m Z m Z m Z m Z ddlmZmZddlmZdd lmZd gZeZd ed <e d ZGdd e eZy)) annotationsN) b64decode)datetime)castUnionAnyOptionalDictTypeVarGeneric)_convert_to_isoformatTZ_UTC)_get_json_content)NULL CloudEventr_UnsetDataTypec eZdZUdZded< ded< dZded< ded< ded < d ed < d ed < d ed< d ed< ded< ddedddddd ddZddZe ddZ e ddZ y)raProperties of the CloudEvent 1.0 Schema. All required parameters must be populated in order to send to Azure. :param source: Required. Identifies the context in which an event happened. The combination of id and source must be unique for each distinct event. If publishing to a domain topic, source must be the domain topic name. :type source: str :param type: Required. Type of event related to the originating occurrence. :type type: str :keyword specversion: Optional. The version of the CloudEvent spec. Defaults to "1.0" :paramtype specversion: str :keyword data: Optional. Event data specific to the event type. :paramtype data: object :keyword time: Optional. The time (in UTC) the event was generated. :paramtype time: ~datetime.datetime :keyword dataschema: Optional. Identifies the schema that data adheres to. :paramtype dataschema: str :keyword datacontenttype: Optional. Content type of data value. :paramtype datacontenttype: str :keyword subject: Optional. This describes the subject of the event in the context of the event producer (identified by source). :paramtype subject: str :keyword id: Optional. An identifier for the event. The combination of id and source must be unique for each distinct event. If not provided, a random UUID will be generated and used. :paramtype id: Optional[str] :keyword extensions: Optional. A CloudEvent MAY include any number of additional context attributes with distinct names represented as key - value pairs. Each extension must be alphanumeric, lower cased and must not exceed the length of 20 characters. :paramtype extensions: Optional[dict] strsourcetypez1.0 specversionidOptional[DataType]dataOptional[datetime]time Optional[str] dataschemadatacontenttypesubjectOptional[Dict[str, Any]] extensionsN)rrrr!r r"rr$c 6||_||_|r||_|r|ntt j |_||turtjt|_ n||_ ||_ ||_ ||_| |_| |_|j rJ|j j#D]-} | j%r| j'r$t)d| r1dj+| j#} t)d| ddzy)Nz V,DIDI.=)3&- (, 4> ??++- e{{}CKKM$%cdd e  &++-0I/ {"=XY  cdj|j|j|j|j|j ddS)Nz>CloudEvent(source={}, type={}, specversion={}, id={}, time={})i)formatrrrrr)r.s r2__repr__zCloudEvent.__repr__s@OVV KKD$4$4dggtyy 4 r4c i}gd}dvrdvr tddvrjd}||nt|d<nz'CloudEvent.from_dict..s u  s)r" eventTyper dataVersionr eventTimezThe event you are trying to parse follows the Eventgrid Schema. You can parse EventGrid events using EventGridEvent.from_dict method in the azure-eventgrid library.zThe event does not conform to the cloud event spec https://github.com/cloudevents/spec. The `source` and `type` params are required.r;) r,getrrrrrbytesitemsrKeyErrorall) clsr=r/ reserved_attrritemvalkvr$ event_objerrs ` r2 from_dictzCloudEvent.from_dicts"$   U?}5_` ` U?99V$D%)%5T4F6N e #&tE#u*,=uyy?W'XYF6N@ @Du}iio&)os4t  @ (-{{}Otq!8NadO O #-F<  99T?X6]!IIm4*599V+<=   I>IP    !pB ' s%7 D D A D&& E /,EE cBt|}tj|S)aReturns the deserialized CloudEvent object when a json payload is provided. :param event: The json string that should be converted into a CloudEvent. This can also be a storage QueueMessage, eventhub's EventData or ServiceBusMessage :type event: object :rtype: CloudEvent :return: The deserialized CloudEvent object. :raises ValueError: If the provided JSON is invalid. )rrrO)rGr= dict_events r2 from_jsonzCloudEvent.from_jsons'u- ##J//r4)rrrrrrrrrrr!rr rr"rrrr$r#r/rreturnNone)rSr)r=zDict[str, Any]rSCloudEvent[DataType])r=rrSrU) __name__ __module__ __qualname____doc____annotations__rrr3r7 classmethodrOrRr;r4r2rrs:< Kt I>K@ Ge 0 45""% !)(;&* #))-$(!%#'/3,,, # ,  ,!,',",,!,-,, ,\ HHT 0 0r4) __future__rr&base64rrtypingrrrr r r r utils._utilsrrutils._messaging_sharedr serializationr__all__objectrrZrrr;r4r2rdsY# EEE76 .h : L0"L0r4