JezK
Edit File: handler.pyc
� \��ic @ s� d d l Z d d l Z d d l Z y d d l Z Wn e k rS d d l Z n Xy e Wn e k r{ e e f Z n Xd d l m Z d e j e f d � � YZ d e j f d � � YZ d S( i����N( t sendert FluentRecordFormatterc B s� e Z d Z d d d e e d d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z e d � � Z RS( s7 A structured formatter for Fluent. Best used with server storing data in an ElasticSearch cluster for example. :param fmt: a dict or a callable with format string as values to map to provided keys. If callable, should accept a single argument `LogRecord` and return a dict, and have a field `usesTime` that is callable and return a bool as would `FluentRecordFormatter.usesTime` :param datefmt: strftime()-compatible date/time format string. :param style: '%', '{' or '$' (used only with Python 3.2 or above) :param fill_missing_fmt_key: if True, do not raise a KeyError if the format key is not found. Put None if not found. :param format_json: if True, will attempt to parse message as json. If not, will use message as-is. Defaults to True :param exclude_attrs: switches this formatter into a mode where all attributes except the ones specified by `exclude_attrs` are logged with the record as is. If `None`, operates as before, otherwise `fmt` is ignored. Can be an iterable. t %c C s� t t | � j d | � t j d d !d k r� | d k r� i t j i d d 6d d 6d d 6f d 6t j i d d 6d d 6d d 6f d 6| \ | _ } n$ d | _ i d d 6d d 6d d 6} | d k rt | � | _ d | _ | j | _ t t | � j | _ n{ d | _ | s:| | _ | j | _ | j | _ nH t | d � ra| | _ | j | _ n! | | _ | j | _ | j | _ | r�| j | _ n | j | _ t j � | _ | | _ d S( Ni i i R s {hostname}t sys_hosts {name}t sys_names {module}t sys_modulet {s ${hostname}s ${name}s ${module}t $s %(hostname)ss %(name)ss %(module)st __call__( i i ( t superR t __init__t Nonet syst version_infot loggingt StrFormatStylet StringTemplateStylet _FluentRecordFormatter__stylet sett _exc_attrst _fmt_dictt _format_by_exclusiont _formattert usesTimet _format_by_dictt _format_by_dict_uses_timet hasattrt _format_msg_jsont _format_msgt _format_msg_defaultt sockett gethostnamet hostnamet fill_missing_fmt_key( t selft fmtt datefmtt styleR! t format_jsont exclude_attrst basic_fmt_dict( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR ) sL " c C sE t t | � j | � | j | _ | j | � } | j | | � | S( N( R R t formatR R t _structuring( R" t recordt data( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR) _ s c C s d S( sT This method is substituted on construction based on settings for performance reasonsN( ( R" ( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR k t c C st | j } t | t � r+ | j | | � nE t | t � rY | j | | j | | � � n | j | i | d 6� d S( s} Melds `msg` into `data`. :param data: dictionary to be sent to fluent server :param msg: :class:`LogRecord`'s message to add to `data`. `msg` can be a simple string for backward compatibility with :mod:`logging` framework, a JSON encoded string or a dictionary that will be merged into dictionary generated in :meth:`format. t messageN( t msgt isinstancet dictt _add_dict basestringR ( R" R, R+ R/ ( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR* n s c C sa y< t j t | � � } t | t � r+ | S| j | | � SWn t k r\ | j | | � SXd S( N( t jsont loadst strR0 R1 R t ValueError( R" R+ R/ t json_msg( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR � s c C s i t t | � j | � d 6S( NR. ( R R R) ( R" R+ R/ ( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR � s c C sF i } x9 | j j � D]( \ } } | | j k r | | | <q q W| S( N( t __dict__t itemsR ( R" R+ R, t keyt value( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR � s c C s� i } x� | j j � D]y \ } } y5 | j rI | j | � j | � } n | | j } Wn+ t k r� } d } | j s� | � q� n X| | | <q W| S( N( R R: R R) R9 t KeyErrorR R! ( R" R+ R, R; R< t exc( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR � s c C sS | j r | j j } n d } t g | j j � D] } | j | � d k ^ q1 � S( Ns %(asctime)i ( R t asctime_searcht anyR t valuest find( R" t searchR< ( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR � s c C sC x< | j � D]. \ } } t | t � r | | t | � <q q Wd S( N( R: R0 R3 R6 ( R, t dicR; R< ( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR2 � s N( t __name__t __module__t __doc__R t Falset TrueR R) R R* R R R R R t staticmethodR2 ( ( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR s 5 t FluentHandlerc B sq e Z d Z d d d e d d e d � Z d � Z e d � � Z d � Z d � Z d � Z d � Z d � Z RS( s% Logging Handler for fluent. t localhosti�^ g @c K sn | | _ | | _ | | _ | | _ | | _ | | _ | | _ | | _ | | _ d | _ t j j | � d S( N( t tagt _hostt _portt _timeoutt _verboset _buffer_overflow_handlert _msgpack_kwargst _nanosecond_precisiont _kwargsR t _senderR t HandlerR ( R" RM t hostt portt timeoutt verboset buffer_overflow_handlert msgpack_kwargst nanosecond_precisiont kwargs( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR � s c C s t j S( N( R t FluentSender( R" ( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyt getSenderClass� s c C sv | j d k ro | j d | j d | j d | j d | j d | j d | j d | j d | j | j � | _ n | j S( NRM RX RY RZ R[ R\ R] R^ ( RV R t getSenderInstanceRM RN RO RP RQ RR RS RT RU ( R" ( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR � s c K sC | j � } | | d | d | d | d | d | d | d | | �S( NRX RY RZ R[ R\ R] R^ ( Ra ( R" RM RX RY RZ R[ R\ R] R^ R_ t sender_class( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyRb � s c C sO | j | � } | j } | j d | j r< t j | j � n t | j � | � S( N( R) R t emit_with_timeR R^ t EventTimet createdt int( R" R+ R, RV ( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyt emit� s c C sH | j � z, z | j j � Wd t t | � j � XWd | j � Xd S( N( t acquireR t closeR RK t release( R" ( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyRj � s c C s | S( N( ( R" ( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyt __enter__� s c C s | j � d S( N( Rj ( R" t exc_typet exc_valt exc_tb( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyt __exit__ s N( RE RF RG RH R R Ra t propertyR Rb Rh Rj Rl Rp ( ( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyRK � s ( R R R t simplejsonR4 t ImportErrorR3 t NameErrorR6 t bytest fluentR t Formattert objectR RW RK ( ( ( s? /opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyt <module> s �