ó O'—^c@@s2dZddlmZddlZddlZddlZddlZyddlZ Wne k rodZ nXddl m Z ddlmZddlmZmZmZmZddlmZmZmZdd lmZdd lmZmZd d d ddgZeddgƒZ eddgƒZ!ej"j#dƒrKd„Z$n ej%Z$e p]eZej&Z'e(ej)j*ddƒƒZ+e dd3ƒZ,ee-fefd„ƒZ.e'd„Z/d„Z0de1fd „ƒYZ2e2ƒZ3e3j4Z5Z4e3j%Z6Z%e3j7Z7e3j8Z8d!„Z9d"„Z:d#„Z;ej<dd$krHd%„Z=ne/Z=d&„Z>d'„Z?e:ƒe>ƒe;ƒe?ƒe3j@d(ƒie:d(6e>d 6e;d)6e?d*6e:d+6e;d,6e>d-6e?d.6ZAd d)d*gd/„ZBd(gd0„ZCeCƒx*ed1ƒD]\ZDZEe7eDjFeEŒqÿWe3jGd2„ZHdS(4sD kombu.serialization =================== Serialization utilities. i(tabsolute_importN(t namedtuple(tcontextmanageri(tContentDisallowedt DecodeErrort EncodeErrortSerializerNotInstalled(tBytesIOtreraisettext_t(t entrypoints(t str_to_bytestbytes_ttpickletloadstdumpstregistert unregistertbinarys ascii-8bitsapplication/datasapplication/texttjavacC@stj|ƒ|ƒdS(Ni(tcodecst getdecoder(tttcoding((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pyt_decode$stPICKLE_PROTOCOLitcodect content_typetcontent_encodingtencodercc@sVy dVWnF|k r‚n3|k rQ}t|||ƒtjƒdƒnXdS(Ni(Rtsystexc_info(twrappertincludetexcludetexc((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pyt_reraise_errors3s   cC@s|t|ƒƒS(N(R(tstload((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pyt pickle_loads>scC@s|rd||fS|S(Ns%s (%s)((tfirsttsecond((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pytparenthesize_aliasCstSerializerRegistrycB@szeZdZd„Zdd„Zd„Zd„Zd„Zd„Zd d„Z e Z d e e d „ZeZd „ZRS( s2The registry keeps track of serialization methods.cC@sOi|_i|_d|_d|_d|_tƒ|_i|_i|_ dS(N( t _encoderst _decoderstNonet_default_encodet_default_content_typet_default_content_encodingtsett_disabled_content_typest type_to_namet name_to_type(tself((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pyt__init__Js       sutf-8cC@sV|r"t|||ƒ|j|RRBR.RRGtFalsetTRUSTED_CONTENTRRSRM(((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pyR+Gs    cC@s_d}|}t|tƒrLd}ttddƒ|j|ƒ}WdQXnd}|||fS(sSpecial case serializer.sapplication/datasutf-8R"NR((RFR R$RRG(RHRRJR((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pyRD'sc@sHddlm‰m}‡fd†}tjd||ddddƒd S( s2Register a encoder/decoder for JSON serialization.i(RRc@s+t|tƒr!|jdƒ}nˆ|ƒS(Nsutf-8(RFR RS(tobj(t json_loads(s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pyt_loads8stjsonRsapplication/jsonRsutf-8N(tanyjsonRRtregistryR(t json_dumpsR]((R\s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pyt register_json4s cC@sly5ddl}tjd|j|jddddƒWn0tk rgd„}tjdd|dƒnXdS( s²Register a encoder/decoder for YAML serialization. It is slower than JSON, but allows for more data types to be serialized. Useful if you need to send data such as datesiNtyamlRsapplication/x-yamlRsutf-8c_@stdƒ‚dS(sOIn case a client receives a yaml message, but yaml isn't installed.s9No decoder installed for YAML. Install the PyYAML libraryN(R(targstkwargs((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pyt not_availableNs(RcR`Rt safe_dumpt safe_loadt ImportErrorR.(RcRf((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pyt register_yamlBs    icC@stt|ƒƒS(N(R'R (R%((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pytunpickleXscC@s2tjd„}tjd|tddddƒdS(sJThe fastest serialization method, but restricts you to python clients.cS@s||dtƒS(Ntprotocol(tpickle_protocol(R[tdumper((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pyt pickle_dumpscsR Rsapplication/x-python-serializeRRN(R RR`RRk(Ro((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pytregister_pickle_sc@sÃd}}yiddl}|jdkr_ddlm‰m‰‡fd†}‡fd†}nd„}|}}Wn*ttfk rŸd„}|}}nXtjd ||d d d d ƒdS(s#See http://msgpack.sourceforge.net/iNi(tpackbtunpackbc@sˆ|dtƒS(Nt use_bin_type(tTrue(R%(Rq(s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pytpackssc@sˆ|ddƒS(Ntencodingsutf-8((R%(Rr(s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pytunpackvsc_@stdƒ‚dS(Ns(msgpack requires msgpack-python >= 0.4.0(R(RdRe((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pytversion_mismatchysc_@stdƒ‚dS(NsKNo decoder installed for msgpack. Please install the msgpack-python library(R(RdRe((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pyRf~stmsgpackRsapplication/x-msgpackRR(ii( R.RytversionRqRrRit ValueErrorR`R(RuRwRyRxRf((RqRrs5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pytregister_msgpackks      R^RcRysapplication/jsonsapplication/x-yamlsapplication/x-python-serializesapplication/x-msgpackcC@s:x3|D]+}ytj|ƒWqtk r1qXqWdS(sØEnable serializers that are considered to be unsafe. Will enable ``pickle``, ``yaml`` and ``msgpack`` by default, but you can also specify a list of serializers (by name or content type) to enable. N(R`R<R@(tchoicestchoice((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pytenable_insecure_serializersŸs   cC@sRxtjD]}tj|ƒq W|dk rNx|D]}tj|ƒq4WndS(sGDisable untrusted serializers. Will disable all serializers except ``json`` or you can specify a list of deserializers to allow. .. note:: Producers will still be able to serialize data in these formats, but consumers will not accept incoming data using the untrusted content types. N(R`R-R>R.R<(tallowedR8((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pytdisable_insecure_serializers®s   skombu.serializersc@s*|dk r&t‡fd†|DƒƒS|S(Nc3@s+|]!}d|kr|nˆ|VqdS(R:N((t.0tn(R5(s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pys Ìs(R.R2(tlR5((R5s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pytprepare_accept_contentÊs (RRR(IRXt __future__RRtosRR tpypickletcPickletcpickleRiR.t collectionsRt contextlibRt exceptionsRRRRtfiveRRR tutilsR tutils.encodingR R t__all__t frozensetRORZtplatformt startswithRRSR&t pickle_loadtinttenvironRERmRt ExceptionR$R'R*tobjectR+R`RGRRRRRDRbRjt version_infoRkRpR|RBt _setupfunsRRtepRdR8R5R…(((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/serialization.pyts~      "      ƒ !