o iw @sxddlZddlmZddlZddlmZddlmZddlZ ej p"dZ Gdddej Z d dd Z ed kr:e dSdS) N)Decimal)stdout)UUIDzUTF-8c@seZdZddZdS)CleanJSONEncodercCsRt|tjtjfr |St|ttfrt|St|tr"|dSt j ||S)Nz iso-8859-1) isinstancedatetimedate isoformatrrstrbytesdecodejson JSONEncoderdefault)selfobjrW/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/fastavro/__main__.pyr s  zCleanJSONEncoder.defaultN)__name__ __module__ __qualname__rrrrrr s rc Csddl}ddlm}|p|j}|dd}|jdddd|jd d d d d |jddd d d |jddd d d |jdddtjd|jdddd d d ||dd}|jrht d t tj j td|jpmdg}|D]b}|dkr{|jj}nt|d}t|}|jrtj|j|jdd|jdqp|jr|jd=tj|j|jdd|jdqp|jrdnd} |D]} tj| |j| td |jd|jqqpdS)!Nr)ArgumentParserz)iter over avro file, emit records as JSON) descriptionfilez#file(s) to parse, use `-' for stdin*)helpnargsz--schemazdump schema instead of records store_trueF)ractionrz --metadataz dump metadata instead of recordsz--codecszprint supported codecsz --versionversionz fastavro )rrz-pz--prettyzpretty print json -rb)indentz avro.schema)r%cls)sysargparserargv add_argumentavro __version__ parse_argscodecsprintjoinsortedread BLOCK_READERSexitrstdinbufferopenreaderschemar dumprwritemetadataprettyrflush) r)r'rparserargsfilesfilenamefor8r%recordrrrmainsh            rE__main__)N)rdecimalrr r'ruuidrfastavror+encodingrrrErrrrrs     >