Wheelodex » Projects » lorrystream

lorrystream

View on PyPI — Reverse Dependencies (2)

0.0.6 lorrystream-0.0.6-py3-none-any.whl

Wheel Details

Project: lorrystream
Version: 0.0.6
Filename: lorrystream-0.0.6-py3-none-any.whl
Download: [link]
Size: 61298
MD5: b00f159075495d0365e28baf0c077d0d
SHA256: 0825d0cdf9cd0cea2b2a17781e81e1c28bfb3c984945e6b5b2efe9b52157e462
Uploaded: 2024-09-02 10:22:50 +0000

dist-info

METADATA · WHEEL · RECORD · top_level.txt · entry_points.txt

METADATA

Metadata-Version: 2.1
Name: lorrystream
Version: 0.0.6
Summary: A lightweight and polyglot stream-processing library, to be used as a data backplane-, message relay-, or pipeline-subsystem.
Author-Email: Andreas Motl <andreas.motl[at]panodata.org>, Richard Pobering <richard.pobering[at]panodata.org>
Project-Url: Changelog, https://lorrystream.readthedocs.io/changes.html
Project-Url: Documentation, https://lorrystream.readthedocs.io/
Project-Url: Homepage, https://lorrystream.readthedocs.io/
Project-Url: Issues, https://github.com/daq-tools/lorrystream/issues
Project-Url: Repository, https://github.com/daq-tools/lorrystream
License: LGPL 3, EUPL 1.2
Keywords: amqp,data,export,import,kinesis,mqtt,pandas,rdbms,sql,stream
Classifier: Development Status :: 3 - Alpha
Classifier: Environment :: Console
Classifier: Intended Audience :: Customer Service
Classifier: Intended Audience :: Developers
Classifier: Intended Audience :: Education
Classifier: Intended Audience :: End Users/Desktop
Classifier: Intended Audience :: Information Technology
Classifier: Intended Audience :: Manufacturing
Classifier: Intended Audience :: Science/Research
Classifier: Intended Audience :: System Administrators
Classifier: Intended Audience :: Telecommunications Industry
Classifier: License :: OSI Approved :: European Union Public Licence 1.2 (EUPL 1.2)
Classifier: License :: OSI Approved :: GNU Lesser General Public License v3 (LGPLv3)
Classifier: Operating System :: MacOS :: MacOS X
Classifier: Operating System :: Microsoft :: Windows
Classifier: Operating System :: POSIX :: Linux
Classifier: Operating System :: Unix
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3 :: Only
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Topic :: Adaptive Technologies
Classifier: Topic :: Communications
Classifier: Topic :: Database
Classifier: Topic :: Documentation
Classifier: Topic :: Education
Classifier: Topic :: Internet
Classifier: Topic :: Internet :: WWW/HTTP
Classifier: Topic :: Office/Business
Classifier: Topic :: Scientific/Engineering
Classifier: Topic :: Software Development :: Embedded Systems
Classifier: Topic :: Software Development :: Libraries
Classifier: Topic :: Software Development :: Object Brokering
Classifier: Topic :: Software Development :: Pre-processors
Classifier: Topic :: Software Development :: Quality Assurance
Classifier: Topic :: Software Development :: Testing
Classifier: Topic :: Software Development :: Version Control
Classifier: Topic :: System :: Archiving
Classifier: Topic :: System :: Benchmark
Classifier: Topic :: System :: Clustering
Classifier: Topic :: System :: Distributed Computing
Classifier: Topic :: System :: Hardware
Classifier: Topic :: System :: Logging
Classifier: Topic :: System :: Monitoring
Classifier: Topic :: System :: Networking
Classifier: Topic :: System :: Systems Administration
Classifier: Topic :: Text Processing
Classifier: Topic :: Utilities
Requires-Python: >=3.9
Requires-Dist: boltons
Requires-Dist: click (<9)
Requires-Dist: colorama (<1)
Requires-Dist: colorlog
Requires-Dist: commons-codec
Requires-Dist: dask
Requires-Dist: funcy
Requires-Dist: influxdb
Requires-Dist: influxdb-client[ciso]
Requires-Dist: paho-mqtt
Requires-Dist: pandas (<2.3)
Requires-Dist: pika (<1.4)
Requires-Dist: simplejson (<4)
Requires-Dist: sqlalchemy (==2.0.*)
Requires-Dist: sqlalchemy-cratedb (>=0.38.0)
Requires-Dist: streamz
Requires-Dist: tomli
Requires-Dist: toolz
Requires-Dist: lorrystream[carabas]; extra == "all"
Requires-Dist: aiobotocore (==2.13.*); extra == "carabas"
Requires-Dist: async-kinesis (<1.2); extra == "carabas"
Requires-Dist: aws-lambda-layer (<0.6); extra == "carabas"
Requires-Dist: boto3 (<1.36,>=1.34); extra == "carabas"
Requires-Dist: cottonformation (<1.2); extra == "carabas"
Requires-Dist: localstack[base-runtime] (<3.7); extra == "carabas"
Requires-Dist: black (<25); extra == "develop"
Requires-Dist: mypy (<1.12); extra == "develop"
Requires-Dist: pika-stubs (<0.2); extra == "develop"
Requires-Dist: poethepoet (<0.28); extra == "develop"
Requires-Dist: pyproject-fmt (<2.3); extra == "develop"
Requires-Dist: ruff (<0.6); extra == "develop"
Requires-Dist: validate-pyproject (<0.20); extra == "develop"
Requires-Dist: furo (==2024.1.29); extra == "docs"
Requires-Dist: myst-parser[linkify] (<5,>=0.18); extra == "docs"
Requires-Dist: sphinx-autobuild (==2021.3.14); extra == "docs"
Requires-Dist: sphinx-copybutton; extra == "docs"
Requires-Dist: sphinx-design-elements (<1); extra == "docs"
Requires-Dist: sphinxcontrib-mermaid (<1); extra == "docs"
Requires-Dist: sphinxext-opengraph (<1); extra == "docs"
Requires-Dist: build (<2); extra == "release"
Requires-Dist: twine (<6); extra == "release"
Requires-Dist: cratedb-toolkit[testing] (==0.0.15); extra == "test"
Requires-Dist: docker (<8); extra == "test"
Requires-Dist: localstack-utils (<1.1); extra == "test"
Requires-Dist: pytest (<9); extra == "test"
Requires-Dist: pytest-asyncio-cooperative (<0.30); extra == "test"
Requires-Dist: pytest-cov (<6); extra == "test"
Requires-Dist: pytest-mock (<4); extra == "test"
Requires-Dist: pytest-mqtt (<0.5,>=0.4.2); extra == "test"
Requires-Dist: requests (==2.28.1); extra == "test"
Requires-Dist: testcontainer-python-rabbitmq (==0.4.*); extra == "test"
Provides-Extra: all
Provides-Extra: carabas
Provides-Extra: develop
Provides-Extra: docs
Provides-Extra: release
Provides-Extra: test
Description-Content-Type: text/x-rst
License-File: LICENSE
[No description]

WHEEL

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

RECORD

Path Digest Size
lorrystream/__init__.py sha256=VL0gHy9RNY0rdaBZYvETPEv9yyaU2O_x2Iu7PAGnJEI 169
lorrystream/cli.py sha256=NHsVGW6gDOMJAgCfHE2Gvt5sDpBF_We6dpIQOn0xs1w 2259
lorrystream/cmd.py sha256=HA7I_EUP6QdtkvgMXTlVk4qanstdZXotFAYavatCZ4E 1167
lorrystream/core.py sha256=7MAcfkYBtrUojb-663KfcqQOIGlqH3iPkiDpXvUrzM4 7025
lorrystream/exceptions.py sha256=qxDAPkmV77VniuuO65myDELe8ok1bEqScrZt1hZx0eU 280
lorrystream/model.py sha256=SdJu7QP5SlM6gs1_a9LHCbTkxuzp-NukPms7RKCOOHA 3511
lorrystream/carabas/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
lorrystream/carabas/aws/__init__.py sha256=7AUbsiV3Gwb8FD-y4hRxgyIp2gLtZxPNpFHbcHM6_7g 400
lorrystream/carabas/aws/model.py sha256=Pgs9IbrbCn0X7zgaRniDNCEV2Mfe4J0urmwEjVuBFZY 5377
lorrystream/carabas/aws/cf/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
lorrystream/carabas/aws/cf/dms_next.py sha256=-Lp8KbXGfJgJLYlo-GiRT6lPn07JlFVJVIFxJoC6_9A 15599
lorrystream/carabas/aws/function/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
lorrystream/carabas/aws/function/model.py sha256=6kKsyBVM1PIj-_7M9kpjFenjzi9c66pIr6IEGS-Lpeo 5360
lorrystream/carabas/aws/function/oci.py sha256=fjWDdD737SzDzYwA4XZQuNsn8U4JZcvJfFrs5KQvIJI 9301
lorrystream/carabas/aws/function/zip.py sha256=kurwXfHj4H0bZl6VHHgX26aROGBfP5CxXYS5P7OzZCs 7760
lorrystream/carabas/aws/stack/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
lorrystream/carabas/aws/stack/dms.py sha256=SH9S28ahavS-eujXe1NU7YqgsW6MnKy1ENtRVVXIXrc 30604
lorrystream/carabas/aws/stack/dynamodb.py sha256=IIPsE1VEfxFAvW6MFFSooCU7HG1CqJ_dp5vS8_Uyceg 5428
lorrystream/process/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
lorrystream/process/kinesis_cratedb_lambda.py sha256=Skg4_LHqfP87tsLwZAn-QH2aD1sGDDrV0IQRngKwCPo 5614
lorrystream/spike/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
lorrystream/spike/kcl_dynamodb/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
lorrystream/spike/kcl_dynamodb/dynamodb_cdc_processor.py sha256=M7LoYhQz0Ee39oa-yadgLx-H62dyzC0Z1FucV5Esy10 8981
lorrystream/spike/kcl_kinesis/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
lorrystream/spike/kcl_kinesis/amazon_kclpy_helper.py sha256=wI8D0cKMMo4zgqNacWvQuE04tazMXp6FnHnSXnpcaF0 7140
lorrystream/spike/kcl_kinesis/record_processor.py sha256=xgOT9enwLPYKe2FG1jRbebcOcI--qkNims4KZmipnyg 7410
lorrystream/spike/kinesis/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
lorrystream/streamz/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
lorrystream/streamz/amqp.py sha256=giwO54_SFV8HwAeeE7bpqQ3LzujSDTaxxxGstDTtANk 19739
lorrystream/streamz/model.py sha256=XuR7k5ltDe7z3Pr_I10g3Yr_-H2NRUH6JhaD1G7VI0A 4066
lorrystream/streamz/sinks.py sha256=9B-9mdhyEzuD3zFI1CtMulc41518tSq9ULV2MMqEy5A 3741
lorrystream/streamz/sources.py sha256=EZIRlSiengKMYjMi_rLoaslHCgkkmkZQcwl8T0_GDlU 3076
lorrystream/util/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
lorrystream/util/about.py sha256=PCKUFdJBQraG_AaaMx0jQ1yr0dwGZY5oZ2QR_5sE9Yk 3000
lorrystream/util/aio.py sha256=ZOTXPI9XkSMCBj26RTjp4bEwGEOvO4Kr8Q6A1b9uEH4 1383
lorrystream/util/cli.py sha256=sFAsWJAEHh2YKOzMW0uG0Gicrrp1c__QDgZ010fGFQA 1523
lorrystream/util/common.py sha256=K3yVXlfPZM9Z4lLDAFzentvbeH-QBiMoEKiTZab13z8 1797
lorrystream/util/data.py sha256=yOrvMnyKWucopZxjz39f6RW__Ho6kJQWQf1oW72pSuY 2499
lorrystream/util/python/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
lorrystream/util/python/bundle.py sha256=g-cOSXhtnkx0it_rcZrLCYIgxpcC8_8Swsrv3BX1Wmo 628
lorrystream/util/python/pep723.py sha256=bUnlrXLzPOuZBa9jmIVxcbohotyPErqZm6bgZTZkmFk 879
lorrystream-0.0.6.dist-info/LICENSE sha256=46mU2C5kSwOnkqkw9XQAJlhBL2JAf1_uCD8lVcXyMRg 7652
lorrystream-0.0.6.dist-info/METADATA sha256=cXpL61z6aj1ZIeHsCzmHZJvqDJ-4HElvIKTe_KVlMhM 5615
lorrystream-0.0.6.dist-info/WHEEL sha256=UvcQYKBHoFqaQd6LKyqHw9fxEolWLQnlzP0h_LgJAfI 91
lorrystream-0.0.6.dist-info/entry_points.txt sha256=WgkOoTIKshsQVcuTYlY2VSUobtAzoytkrqO6GHqVlPk 254
lorrystream-0.0.6.dist-info/top_level.txt sha256=Xsk8p0uKb0ueGpohsr-aui39F3SiPXHqe7nJaS_M060 12
lorrystream-0.0.6.dist-info/RECORD — —

top_level.txt

lorrystream

entry_points.txt

[console_scripts]
lorry = lorrystream.cli:cli
[streamz.sinks]
dataframe_to_sql = lorrystream.streamz.sinks:dataframe_to_sql
[streamz.sources]
from_amqp = lorrystream.streamz.sources:from_amqp
from_mqtt_plus = lorrystream.streamz.sources:from_mqtt_plus