streamparse

View on PyPIReverse Dependencies (1)

5.0.1 streamparse-5.0.1-py2.py3-none-any.whl

Wheel Details

Project: streamparse
Version: 5.0.1
Filename: streamparse-5.0.1-py2.py3-none-any.whl
Download: [link]
Size: 78346
MD5: e6111bfd705e3c6b51d1831a46070faa
SHA256: 0afdf06c3d64d12425839ddda729c3d8b4a10d9ba6fd9e81a38aeef9288b6ce5
Uploaded: 2024-08-09 15:17:04 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: streamparse
Version: 5.0.1
Summary: streamparse lets you run Python code against real-time streams of data. Integrates with Apache Storm.
Author: Parsely, Inc.
Author-Email: hello[at]parsely.com
Home-Page: https://github.com/Parsely/streamparse
License: Apache License 2.0
Classifier: License :: OSI Approved :: Apache Software License
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.6
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: 3.8
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: Implementation :: CPython
Classifier: Programming Language :: Python :: Implementation :: PyPy
Requires-Dist: cython
Requires-Dist: jinja2
Requires-Dist: Fabric39
Requires-Dist: pystorm (>=3.1.1)
Requires-Dist: requests
Requires-Dist: ruamel.yaml
Requires-Dist: setuptools
Requires-Dist: simplejson
Requires-Dist: texttable
Requires-Dist: thriftpy2
Requires-Dist: cython; extra == "all"
Requires-Dist: jinja2; extra == "all"
Requires-Dist: Fabric39; extra == "all"
Requires-Dist: pystorm (>=3.1.1); extra == "all"
Requires-Dist: requests; extra == "all"
Requires-Dist: ruamel.yaml; extra == "all"
Requires-Dist: setuptools; extra == "all"
Requires-Dist: simplejson; extra == "all"
Requires-Dist: texttable; extra == "all"
Requires-Dist: thriftpy2; extra == "all"
Requires-Dist: graphviz; extra == "all"
Requires-Dist: pytest; extra == "all"
Requires-Dist: sphinx; extra == "docs"
Requires-Dist: graphviz; extra == "docs"
Requires-Dist: pytest; extra == "docs"
Requires-Dist: graphviz; extra == "test"
Requires-Dist: pytest; extra == "test"
Provides-Extra: all
Provides-Extra: docs
Provides-Extra: test
License-File: LICENSE
[Description omitted; length: 2885 characters]

WHEEL

Wheel-Version: 1.0
Generator: setuptools (72.1.0)
Root-Is-Purelib: true
Tag: py2-none-any
Tag: py3-none-any

RECORD

Path Digest Size
streamparse/__init__.py sha256=_XOFvTVMaNzZNS-cgDzr3HrJW4fAF50mzseXXI3T58I 1568
streamparse/bolt.py sha256=sidVlna7c77gw-4ZuWXzJTpA8hsstvf5ZhUqUb72kS4 71
streamparse/component.py sha256=NWYahu7fjdKiZnWwl0TmwURCMMo6JZnFU_khftK0GLw 76
streamparse/run.py sha256=txxQzgk3sUwq_sXSrqI6Avmyil8QOUySonhrRX0uMN8 1671
streamparse/spout.py sha256=64jOKmYE5X6RFqh44yhdPWXKktqG9cXkpWl5G3d-lBw 72
streamparse/thrift.py sha256=1manXBw6vUOXGsF0oBj0IOkKvhw53vc18mVAP1eiqE8 25185
streamparse/util.py sha256=pZTJQZ1MaRUEdeasdhOBzYwgwn5Njcgz_Qs8_GaRXdk 21330
streamparse/version.py sha256=o4aeyI8EbpEHjhfMtCgGJlXdNfKkmzSJ57EEiBNTvZU 1024
streamparse/bootstrap/__init__.py sha256=3O-4O7kINjjgTmwF3B62OsE8RAcEiANazErV_2rxv6g 3336
streamparse/bootstrap/project/config.jinja2.json sha256=MI3SUH_AdTb3_5l0qxp9ax_rVNFycNuSgglv5xif6Bk 468
streamparse/bootstrap/project/fabfile.py sha256=ozpLYL6WWzf557nBHtu81pFn2-hHsgVYVmtiExrTBYg 474
streamparse/bootstrap/project/gitignore sha256=3BMU41upRGdREu_U4pMm3A3cm2PXvSW60xDZTKyVcLU 33
streamparse/bootstrap/project/project.jinja2.clj sha256=QnLeB0t4U8rOtK6B3lApNfUeVn0-zxU-3A3go7mWwDw 517
streamparse/bootstrap/project/src/bolts/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
streamparse/bootstrap/project/src/bolts/wordcount.py sha256=uIm6NR0L2DSZpK8s1cR6v_gGfv8oeN23APxyzasfnjE 673
streamparse/bootstrap/project/src/spouts/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
streamparse/bootstrap/project/src/spouts/words.py sha256=W5YqMgQ1dark4JTfH3wJttXj3XPulKNykKO1djPdLyc 304
streamparse/bootstrap/project/topologies/wordcount.py sha256=bips50MR8ZVKG9EUUTkz3mZ8GhkPrZqRFXrKg1SQo9k 302
streamparse/bootstrap/project/virtualenvs/wordcount.txt sha256=LJG6o5E1zic1LHeDxPx_Et72TJ5SyUoHw-nyqBUF_a4 55
streamparse/cli/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
streamparse/cli/common.py sha256=1jfRk1Wct3cLuqU72QjuqrZspA8jx-MrUP8gSUO9oDs 11237
streamparse/cli/jar.py sha256=CorybCBElk3oshv5fH4rtHBkxA-ej5nUJyFG3EuSsms 2393
streamparse/cli/kill.py sha256=dvpbejCU4-ClbwNbE4VCTnswybALFRC50HxQ-xHDoig 1819
streamparse/cli/list.py sha256=z-M1TTT1WvgK_M8oV3rfYjrB3kUNtGwXiNwdcpPVur4 2457
streamparse/cli/quickstart.py sha256=owJmXR-8mCos6gLKaBtrM391V_AOz9qSZjVMQF0lvJA 514
streamparse/cli/remove_logs.py sha256=ejTkuz6AHDunJzidAL9VRfEjkgv9yv62iP93sWVRE2c 3379
streamparse/cli/run.py sha256=Ubajpb_bKsAO_ggbNoAN2g2ZUrl7_rvnI47jHzG2GtI 4127
streamparse/cli/slot_usage.py sha256=jtDl1WdWeLKlIT7_hAiYERg8QH4LE5Y7pQYu2p2Q73Q 3581
streamparse/cli/sparse.py sha256=1RfAHXL8b0ok2ILIbiTYh4CIuyHFV3UA_OXYFZRJ6eU 3152
streamparse/cli/stats.py sha256=8KLm3eILYkglDLK7hrfw4RtEXtf1MGnHzIcUyV_lz9Q 9785
streamparse/cli/submit.py sha256=j0s5d59Sj6ISpCkLgQxyoFISaHe6h0b-Z2a6p7omWMw 13106
streamparse/cli/tail.py sha256=9zNiHFhZcK0wf8PhOUpazdUb_acUIDYOuGkCXEQRI68 3051
streamparse/cli/update_virtualenv.py sha256=8y2YeUilVAZK67iNOrwKe_L9L2l70eiq4SKndShHQ_Q 6222
streamparse/cli/visualize.py sha256=hpPWwtysASr_XRx9t8i7c0EtgU4FRK50IEgJWeSogaU 6679
streamparse/cli/worker_uptime.py sha256=8H3px0pNZcxZ3g8g-k_XXRW_3wpd_bGDbIDyXBArEIU 2587
streamparse/dsl/__init__.py sha256=Apf9jQwHXbvIZspF9nytX0xX3r2X6zkzCJVajsUQ5eo 103
streamparse/dsl/bolt.py sha256=iz5EqQop2I9emA4INb0lUGQhbcAtju0A-BW1N3J8vSU 1247
streamparse/dsl/component.py sha256=Qxn3kiHR3Ve0LVpWzwoks9ce5KE_iTNOgGrYPBAuC0M 10358
streamparse/dsl/spout.py sha256=_A9EXPWX8w74p9GVq41DogYFaI2tttUWqTWAnGeF3w4 1155
streamparse/dsl/stream.py sha256=tknK5_z19DfYEdKzece5AgBOW1tPgfDzpbD3HTBj0qU 5620
streamparse/dsl/topology.py sha256=Mfk7WWR4BnuVsr7sA7xe28AOLWq2ZnR6N8p_Ys9w5rQ 12331
streamparse/dsl/util.py sha256=fuquXSt-hzN7dLfJGgJT8-a9nwdPF8wBpqwNd_QbUUo 1319
streamparse/storm/__init__.py sha256=y1ViG_Uj_UnG8voAy18LPuv-RayIkefcBddKzlaTUlU 293
streamparse/storm/bolt.py sha256=_EA4eJL7S83NLNlt4TlRtz_-CZBpgI_NVw9jN5nkcoM 8075
streamparse/storm/component.py sha256=kOK35FRu4hKiBgf1apT5LB3O7oqt3tvtkeVuD8UeISc 689
streamparse/storm/spout.py sha256=bDyzIKx49GzeGg6jdxBftqHSSpZxn38LIpWsiozm4KE 6136
test/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
test/streamparse/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
test/streamparse/test_dsl.py sha256=QEFdkO-XH3sLmnuH58i6u0If3VgtfLgV_qf7atLrw2w 23353
test/streamparse/test_streamparse_run.py sha256=JYupy2kbyX89P5EorQ7jd2IFrXTj_JZvvfdbnXc86S4 1843
test/streamparse/cli/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
test/streamparse/cli/test_attach.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
test/streamparse/cli/test_common.py sha256=LdAbZ6gSWvmc5IjIJtr1vCcKTAxaEp21NqEFfr6M14I 2160
test/streamparse/cli/test_jar.py sha256=DQp1nLS_npXNVjuk6U8vYMfl4FfWJjwZHUBpOzl7b-c 316
test/streamparse/cli/test_kill.py sha256=dVU7XfNd2jX7zX65xNJFKIOAvqZA2lgf2N4e4zkkS2k 318
test/streamparse/cli/test_list.py sha256=ApssRFv_sLYx3A9uCwRQ1HFk3q2dOfnVtkw6lV9ruQk 318
test/streamparse/cli/test_logs.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
test/streamparse/cli/test_quickstart.py sha256=DprXsvONuKyT-Olrm-DQQZnMucDhn-kWOubh2frTrII 330
test/streamparse/cli/test_remove_logs.py sha256=o_kHuCrN5-xpF5WPt0jMrrTNOZ0ip77gPcUmc7Tna_c 332
test/streamparse/cli/test_run.py sha256=spmJs3-l-TqqODhO70wtf5cMOjE_NxmsAPmdyYXV2xA 854
test/streamparse/cli/test_sparse.py sha256=Q2li2Z4wa4SzU1u6Xkq4nuoC14S74nh0s2de3Yxs-LI 426
test/streamparse/cli/test_stats.py sha256=Z3cef2s0Xjpg8YC3dryAtK7AP-40aJ6tgc2ZH1b3dIQ 320
test/streamparse/cli/test_submit.py sha256=6zoRSGFIpFwB1vp513mW07fEfPOBaLb1UbaFv4mPapk 322
test/streamparse/cli/test_tail.py sha256=6lUPmj8VzmbbwbaV_DOtpbzMUCc3Ffgz9B_9dVFffTs 318
test/streamparse/cli/test_update_virtualenv.py sha256=zbYb1taCByU7v8XGkQLn-LNofxqAWIYeL_dlRCj5c7k 344
test/streamparse/cli/test_worker_uptime.py sha256=FusPxRmMj5NInhY1EKYsy1YizHyZiOhZn_eLn2LyDy0 336
test/streamparse_run/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
test/streamparse_run/streamparse_run_target.py sha256=8lu6dAFTSXo_7R1uSLZpAMuPZzH8MdDIhMymW2KuRgo 364
streamparse-5.0.1.dist-info/LICENSE sha256=3_pz_qlZXvg8I71VLO_3mOvOtFUylGNo3srCERvXwgM 10836
streamparse-5.0.1.dist-info/METADATA sha256=CS_4l9pJrI922Gv3iIwIzc0S8xpQTnpiYvOUX20iX5A 4722
streamparse-5.0.1.dist-info/WHEEL sha256=XRxW4r1PNiVhMpP4bT9oWtu3HyndxpJ84SkubFgzp_Y 109
streamparse-5.0.1.dist-info/entry_points.txt sha256=5g_wOT_Hm7brqg9F5zfvJZ7Mr1TCctGXxpuRiFTtS9o 136
streamparse-5.0.1.dist-info/top_level.txt sha256=hYQGMZ56zuAdRQ8_F4_A_Xs4gkTD-QbDdK6NTFoZ08g 17
streamparse-5.0.1.dist-info/RECORD

top_level.txt

streamparse
test

entry_points.txt

sparse = streamparse.cli.sparse:main
streamparse = streamparse.cli.sparse:main
streamparse_run = streamparse.run:main