�
c�ec@s�dd
lZdd
l
Z
dd
lZydd
lZWnek
rS


dd
lZn
Xye
Wnek
r{


ee	fZn
Xddl
mZ
deje
fd��YZdejf
d��YZd
S(i����N(
tsendertFluentRecordFormattercBs�eZ
dZddd
eedd�Zd�Zd�Zd�Z	d�Z
d�Zd�Zd	�Z
d
�Zed��
ZRS(
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
%cCs�
tt
|�jd|�
tjd
d!dkr�|dkr�itjidd6dd6d	d
6fd6tjidd6d
d6dd
6fd6|\|_	}n$d|_	idd6dd6dd
6}|dk	r
t
|�
|_d|_|j
|_tt
|�j|_n{d|_|
s:
||_|j|_|j|_nHt|
d�ra
|
|_|
j|_n!|
|_|j|_|j|_|r�
|j|_n|j|_tj�|_||_dS(NiiiRs
{hostname}tsys_hosts{name}tsys_names{module}t
sys_modulet
{s${hostname}s${name}s	${module}t
$s%(hostname)ss%(name)ss
%(module)st__call__(ii(tsuperR
t__init__tNonetsystversion_infotloggingtStrFormatStyletStringTemplateStylet_FluentRecordFormatter__styletsett
_exc_attrst	_fmt_dictt_format_by_exclusiont
_formattertusesTimet_format_by_dictt_format_by_dict_uses_timethasattrt_format_msg_jsont_format_msgt_format_msg_defaulttsockettgethostnamethostnametfill_missing_fmt_key(tselftfmttdatefmttstyleR!tformat_jsont
exclude_attrstbasic_fmt_dict((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR
)sL"

	


	


	






	

	

	


	
	


cCsEtt
|�j|
�

|j|
_|j|
�
}|j||
�
|S(
N(R	R
tformatR Rt_structuring(R"trecordtdata((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR)_s

c


Csd
S(sTThis method is substituted on construction based on settings for performance reasonsN((
R"((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyRktcCst|j}t
|t�r+|j|
|�
nEt
|t�rY|j|
|j||��
n|j|
i
|d
6�
dS(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.
        tmessageN(tmsgt
isinstancetdictt_add_dict
basestringR(R"R,R+R/((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR*ns		


cCsay<tj
t|�
�
}t|t�r+|S|j|
|�SWntk
r\


|j|
|�SXdS(
N(tjsontloadststrR0R1Rt
ValueError(R"R+R/tjson_msg((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR�s






cCsi
tt
|�j|
�
d
6S(NR.(R	R
R)(R"R+R/((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR�s
cCsFi}x9|
jj
�D](\}}||jkr|||<qqW|S(
N(t__dict__titemsR(R"R+R,tkeytvalue((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR�s





cCs�i}x�|jj
�D]y\}}y5|jrI|j|�
j|
�
}n
||
j}Wn+tk
r�
}
d}|js�|�
q�n
X|||<qW|S(
N(RR:RR)R9tKeyErrorRR!(R"R+R,R;R<texc((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR�s



	



	


c
CsS|jr|jj
}
nd
}
tg|jj�D]}|j|
�
dk^q1�
S(Ns
%(asctime)i(Rtasctime_searchtanyRtvaluestfind(R"tsearchR<((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR�s
	

cCsCx<|
j�D].\}}t
|t�r
||t|�
<q
q
WdS(
N(R:R0R3R6(R,tdicR;R<((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR2�s

N(t__name__t
__module__t__doc__RtFalsetTrueR
R)RR*RRRRRtstaticmethodR2(((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR
s
5				
				t
FluentHandlercBsqeZ
dZd
ddedded�Zd�Zed��
Zd�Z	d�Z
d	�Zd
�Zd�Z
RS(
s%
    Logging Handler for fluent.
    t	localhosti�^g@c	
Ksn|
|_||_
||_||_||_||_||_||_|	|_d|_
tjj
|�

dS(
N(ttagt_hostt_portt_timeoutt_verboset_buffer_overflow_handlert_msgpack_kwargst_nanosecond_precisiont_kwargsRt_senderRtHandlerR
(
R"RMthosttportttimeouttverbosetbuffer_overflow_handlertmsgpack_kwargstnanosecond_precisiontkwargs((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR
�s	
	
	
	
	
	
	
	
	
	
c


Cstj
S(
N(RtFluentSender(
R"((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pytgetSenderClass�s
c

Csv|jdkro|jd
|jd|jd|jd|jd|jd|jd|j	d|j
|j�|_n|jS(	NRMRXRYRZR[R\R]R^(RVRtgetSenderInstanceRMRNRORPRQRRRSRTRU(
R"((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyR�s
	
	
	
	
	
	
	
	

c	KsC|j�}
|
|
d
|d|d|d|d|d|d||	�
S(NRXRYRZR[R\R]R^(
Ra(R"RMRXRYRZR[R\R]R^R_tsender_class((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyRb�s
	




cCsO|j|
�
}|j
}|jd|jr<t
j|
j�
nt|
j�
|�S(
N(R)Rtemit_with_timeRR^t	EventTimetcreatedtint(R"R+R,RV((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pytemit�s

	
	

c

CsH|j�
z,z|j
j�
Wdtt|�j�
XWd|j�
XdS(
N(tacquireRtcloseR	RKtrelease(
R"((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyRj�s




c


Cs|S(
N((
R"((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyt	__enter__�s
c
Cs|j�
dS(
N(
Rj(R"texc_typetexc_valtexc_tb((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyt__exit__
s
N(RERFRGRHRR
RatpropertyRRbRhRjRlRp(((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyRK�s





					
	(RRRt
simplejsonR4tImportErrorR3t	NameErrorR6tbytestfluentRt	FormattertobjectR
RWRK(((s?/opt/alt/python27/lib/python2.7/site-packages/fluent/handler.pyt<module>s









�