openmsistream

View on PyPIReverse Dependencies (0)

1.8.0 openmsistream-1.8.0-py3-none-any.whl

Wheel Details

Project: openmsistream
Version: 1.8.0
Filename: openmsistream-1.8.0-py3-none-any.whl
Download: [link]
Size: 158920
MD5: 45af60e52e224970bdf33f09e5b9bf69
SHA256: 69ae7b3a9bab74f9909a47a5ea150ec9c614ba0451f907da73232851cd286473
Uploaded: 2024-08-29 20:12:30 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: openmsistream
Version: 1.8.0
Summary: Python applications for materials data streaming using Apache Kafka. Developed for Open MSI (NSF DMREF award #1921959)
Author: OpenMSIStream
Author-Email: openmsistream[at]gmail.com
Home-Page: https://github.com/openmsi/openmsistream
Download-Url: https://github.com/openmsi/openmsistream/archive/refs/tags/v1.8.0.tar.gz
License: GNU GPLv3
Keywords: data_streaming,stream_processing,apache_kafka,materials,data_science
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: 3.9
Classifier: License :: OSI Approved :: GNU General Public License v3 (GPLv3)
Classifier: Operating System :: OS Independent
Requires-Python: >=3.7,<3.10
Requires-Dist: atomicwrites (>=1.4.1)
Requires-Dist: boto3 (>=1.26.84)
Requires-Dist: confluent-kafka (>=2.0.2)
Requires-Dist: girder-client (>=3.1.20)
Requires-Dist: kafka-python (>=2.0.2)
Requires-Dist: kafkacrypto (>=0.9.10.3)
Requires-Dist: matplotlib
Requires-Dist: methodtools
Requires-Dist: msgpack
Requires-Dist: openmsitoolbox (>=1.2.3)
Requires-Dist: watchdog (>=3.0.0)
Requires-Dist: beautifulsoup4; extra == "all"
Requires-Dist: black; extra == "all"
Requires-Dist: docker; extra == "all"
Requires-Dist: gitpython; extra == "all"
Requires-Dist: lxml; extra == "all"
Requires-Dist: marko[toc] (==1.3.0); extra == "all"
Requires-Dist: packaging; extra == "all"
Requires-Dist: pyflakes (>=3.0.1); extra == "all"
Requires-Dist: pylint (>=2.16.3); extra == "all"
Requires-Dist: requests; extra == "all"
Requires-Dist: sphinx (>=6.1.3); extra == "all"
Requires-Dist: sphinx-rtd-theme (>=1.2.0); extra == "all"
Requires-Dist: tempenv (>=2.0.0); extra == "all"
Requires-Dist: twine; extra == "all"
Requires-Dist: twine; extra == "dev"
Requires-Dist: sphinx (>=6.1.3); extra == "docs"
Requires-Dist: sphinx-rtd-theme (>=1.2.0); extra == "docs"
Requires-Dist: beautifulsoup4; extra == "test"
Requires-Dist: black; extra == "test"
Requires-Dist: docker; extra == "test"
Requires-Dist: gitpython; extra == "test"
Requires-Dist: lxml; extra == "test"
Requires-Dist: marko[toc] (==1.3.0); extra == "test"
Requires-Dist: packaging; extra == "test"
Requires-Dist: pyflakes (>=3.0.1); extra == "test"
Requires-Dist: pylint (>=2.16.3); extra == "test"
Requires-Dist: requests; extra == "test"
Requires-Dist: tempenv (>=2.0.0); extra == "test"
Provides-Extra: all
Provides-Extra: dev
Provides-Extra: docs
Provides-Extra: test
Description-Content-Type: text/markdown
License-File: LICENSE
[Description omitted; length: 1136 characters]

WHEEL

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

RECORD

Path Digest Size
openmsistream/__init__.py sha256=1ik5FpgNBMU3O_VV_OQQSv5xxIt87tBuYrZ5OuvjGR4 2463
openmsistream/version.py sha256=Oc_xF94AMAHKZkZlB5rBt1iO0TXWFalg65MP4T2qt-A 22
openmsistream/data_file_io/__init__.py sha256=Vqqg6e49ys6tjYgjzhpRwa4HAchbyVlwlUYtjFq6WwI 641
openmsistream/data_file_io/config.py sha256=6j_RjBNoMsm4VWBwyrO08w_0j-x9c8Tgz_KPvxbTEPs 398
openmsistream/data_file_io/utilities.py sha256=amp6-PWOGzxlhyMU3_d0Xz-0uxvoBRRUAfIorwhXcDA 2380
openmsistream/data_file_io/actor/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
openmsistream/data_file_io/actor/data_file_chunk_handlers.py sha256=0QcHSW3Mb_-_ezj6R-7mNbVC0mdp3AJKE3WhPe78vN0 7814
openmsistream/data_file_io/actor/data_file_download_directory.py sha256=VRk3-n798TnfCXznWzUzylkPcBjAYUv8QuxLo74iPFk 10791
openmsistream/data_file_io/actor/data_file_stream_handler.py sha256=aYs6AgGLk4Q9B51OIY_aKbtUaP4CCNWlt87u5K11Bew 8424
openmsistream/data_file_io/actor/data_file_stream_processor.py sha256=m0iH0gjjKjz3vavNN3c6uYoduHn-Kmx06oIW8yHcf1Q 12779
openmsistream/data_file_io/actor/data_file_stream_reproducer.py sha256=-S8mj1jA8yyJrh0hEo1xwgizGhtkoWiry8Ercm4G4pE 18738
openmsistream/data_file_io/actor/data_file_upload_directory.py sha256=pJpnVdP0tkiG21jk-X0HRup4OsVaIeFoQHqTBsVbQtM 34240
openmsistream/data_file_io/actor/file_registry/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
openmsistream/data_file_io/actor/file_registry/producer_file_registry.py sha256=-BBfNZv47yy4YvxAXYv4PZJQ_cN8WKONSpGuZwGoZMA 13928
openmsistream/data_file_io/actor/file_registry/stream_handler_registries.py sha256=aEbH8nz7mr0hYFjFrYVJuVGz5qbaD0w9Oy23DZIFZP8 16845
openmsistream/data_file_io/entity/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
openmsistream/data_file_io/entity/data_file.py sha256=jXlyEhnVEmZ52b_BNC-vE0ZIOq1_l72AD1dTKPzYty0 562
openmsistream/data_file_io/entity/data_file_chunk.py sha256=S-O4ePHp_2vJZzoc4foHXLFCpJiP1T1RxWqpGUSYh6Y 10086
openmsistream/data_file_io/entity/data_file_directory.py sha256=nWE3WF1o599hc3oJQAl1op1ZBN_R_GcN1rzA4pv5GCw 542
openmsistream/data_file_io/entity/download_data_file.py sha256=JZSy3vq03XGNkbUyXUCAMsnR5aSbhz5GsSxgFcWGPO4 13393
openmsistream/data_file_io/entity/reproducer_message.py sha256=4vspMnmZi7MrNtucAvhyjU4JF63C1YrDEKM0OS0CS4s 1757
openmsistream/data_file_io/entity/upload_data_file.py sha256=hbXTmJSG0EeydotJB70jmxFOr7ZiI9lQmaKrULcd7Io 18219
openmsistream/data_file_io/entity/upload_directory_event_handler.py sha256=LR_iIXFKPRjR8GMEiOOBgvDpVYYDtrNh0HMB4hfl33o 6983
openmsistream/girder/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
openmsistream/girder/girder_upload_stream_processor.py sha256=Yfo3i7SQ4gA5bJr5CBRTrQr5hy1zF0gbMw_QkX9pIRo 15228
openmsistream/kafka_wrapper/__init__.py sha256=gy6gPadT8pjQ_CIkLLgky1Rz4yEMji1MHQ4IYKeh_x0 698
openmsistream/kafka_wrapper/config_file_parser.py sha256=0Wj3XHfVvI0aIGrAACTB3q6T7MoNpRbcfJmhIDZ-0qM 7020
openmsistream/kafka_wrapper/consumer_and_producer_group.py sha256=wTrDrS6eHe9w33_sUHIiqK1ag0ID1xmYHw1W85Zfftw 5751
openmsistream/kafka_wrapper/consumer_group.py sha256=k5CvzWy6pUjP5_bBaUoGgIVmVpY2drxuhXNClRjRCVM 9271
openmsistream/kafka_wrapper/controlled_message_processor.py sha256=3aivvvIz3Fx3I_YEz2avO4wvPUgEer0LvFn3G6NhzYI 9263
openmsistream/kafka_wrapper/controlled_message_reproducer.py sha256=CqaTBsMp9aK6eOJkQdw-CMuw7zc7VWufwOoYwOnerBM 13632
openmsistream/kafka_wrapper/openmsistream_consumer.py sha256=q881sVYXBj-Slt4M6vc7tay0UHaaKaMjHQe_8MA0qgo 20618
openmsistream/kafka_wrapper/openmsistream_kafka_crypto.py sha256=IpkIYCemGXlm4YMPdsC8ho7ss_laNdd0-dX5JkUwc1k 4436
openmsistream/kafka_wrapper/openmsistream_producer.py sha256=kQiCGiqNg8z-gR-spW_HR9Oa-EZmorypfd5ip5yOjDA 16208
openmsistream/kafka_wrapper/producer_group.py sha256=2IYczGNaj1iteXn2z3W7M4hUEjcucz1mRtUj1WqFglk 2852
openmsistream/kafka_wrapper/producible.py sha256=bH90D8HpKBbzCAYFf1ARYpW-wI_1HfWE_J-U_Fm94h4 1428
openmsistream/kafka_wrapper/serialization.py sha256=JzGBnP0bwzxwOz9kpiRGr_WzJ4DTmpIqI4CAMdUP_h8 9999
openmsistream/kafka_wrapper/utilities.py sha256=xhVt_NYdtZqb_NQuz4zj1ZokB8hEvodDNeX4NddGAIg 3061
openmsistream/kafka_wrapper/config_files/README.md sha256=TIpO1bYMJyUWUt_QiIh7TgZuiYEmzKGbf6lijFGwICQ 137
openmsistream/kafka_wrapper/config_files/local_broker_test.config sha256=eyOMMBmS5_W6-EFBhlZ5G3ba1MhXPz5tsjsw91nBMco 447
openmsistream/kafka_wrapper/config_files/local_broker_test_encrypted.config sha256=lIs1hKiEC-BpVhzrMchCsfEhZzvKE3y8lk7_87iVwdk 484
openmsistream/kafka_wrapper/config_files/local_broker_test_encrypted_2.config sha256=Ajxv8cMn91fONDUt81ksPUjerAr4gfzjlAC-lsGRBnI 486
openmsistream/kafka_wrapper/config_files/local_broker_test_heartbeats.config sha256=bhDFzi2kjEpEk8PSYG7ZuzRB2LUc9EcqKTBmUAgcPhs 499
openmsistream/kafka_wrapper/config_files/local_broker_test_metadata_rep_consumer.config sha256=ee2FoJiRYu8VXlM3Zm8ApyLn-D6v2O3snDHTtFN9F4o 189
openmsistream/kafka_wrapper/config_files/local_broker_test_s3_transfer.config sha256=Zg7HP4flTFYJRPh5GPyvpJtmlJFEkuIcWUKYRIRqPUY 561
openmsistream/kafka_wrapper/config_files/prod.config sha256=jHdbDPP4jiKYrvNwbrrzsZ4oFXwpTHBZr74hW7rZtMs 601
openmsistream/kafka_wrapper/config_files/test.config sha256=bfM4l8I9YJ2YLBnXMqOVSsABX_xI-XqnjR5KFV8Nz28 600
openmsistream/kafka_wrapper/config_files/test_encrypted.config sha256=yztjvThfuXDsZboUmKuWdLS14qD7f5gFk3K_VwApXaY 637
openmsistream/kafka_wrapper/config_files/test_encrypted_2.config sha256=v7KAq5ndkHeMnQjJvKbMuEMi5pW33XqbYcuRMZafpkE 639
openmsistream/kafka_wrapper/config_files/test_heartbeats.config sha256=Pj1mAw66Ic7hjSCW6azC3GVv4SrC6FvIsqKhP7wzN9E 652
openmsistream/kafka_wrapper/config_files/test_metadata_rep_consumer.config sha256=IzmW84SXNkxKKwHs-5RUkG5mBfJMcM0US2s4kAQqtiI 342
openmsistream/kafka_wrapper/config_files/test_s3_transfer.config sha256=6yLgoXQ8T5hYvzwtXmpSj_gQR7wQC313CO6T5r6Tv00 714
openmsistream/kafka_wrapper/config_files/testing_node/testing_node.config sha256=Pk4QSOb5efJZX4ZMNdnn_WFmqSOzNoQ0ir7-21t64DM 2348
openmsistream/kafka_wrapper/config_files/testing_node/testing_node.crypto sha256=9rM1CxjaWFpy9jm2PqwLUo4XZYVRSfi_KDfBkTZPWB4 105
openmsistream/kafka_wrapper/config_files/testing_node/testing_node.seed sha256=Gj1-RNzN0GVyw_6ZZCVmlZv_7j7XLqyezybCCVY8Io4 36
openmsistream/kafka_wrapper/config_files/testing_node_2/testing_node_2.config sha256=tAPDjPz0MTU7Dwe8uM9cdLhfO8xI3vpffb38sgG3wrg 1196
openmsistream/kafka_wrapper/config_files/testing_node_2/testing_node_2.crypto sha256=S88jQ10zbTULeH8BiDn_hCHnoE7Z70YEI4j012DAhuA 105
openmsistream/kafka_wrapper/config_files/testing_node_2/testing_node_2.seed sha256=q7or5btMdSn-y-sVyLQLVVY7Ov_ppUqtE5UtkcOYIPU 36
openmsistream/metadata_extraction/__init__.py sha256=7eyx5mvsbAYttYhJNlnTDmCvDMeTAbtjk7uhLqzMjdk 151
openmsistream/metadata_extraction/metadata_json_message.py sha256=QJ4wPovO6g4yU9ji-gGbAraJsvDJo-28NUv2G_xlAu0 684
openmsistream/metadata_extraction/metadata_json_reproducer.py sha256=4bX_P-PbfwdNKiKh-Yfc3N7zjxp73eyMvaitVV1knEs 6559
openmsistream/s3_buckets/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
openmsistream/s3_buckets/config_file_parser.py sha256=PBHYIGa18t0VaLpgiMphDHDjrbRUQTO5dUbRHmUn4d8 598
openmsistream/s3_buckets/s3_data_transfer.py sha256=iz2HZSHdKogGnqi0gRmJ_MxSnyOU0lyn9ZKLrZsZYkc 1382
openmsistream/s3_buckets/s3_service.py sha256=rrETU-AcP99HIsb2z9kPyzh1g1MoTuIF7g5KVOZchKI 4033
openmsistream/s3_buckets/s3_transfer_stream_processor.py sha256=tVwjkQ9iD3D552cPh3ebB2ghHygQQy0fGyZUF8Vme5o 6785
openmsistream/services/__init__.py sha256=V7GB_oHQh5Ts5zQ8It89CkM9D7DlcpaJ2Q6zPJB61Ik 281
openmsistream/services/config.py sha256=RLIZqMwmgzVSlkrxDKvSDkKhBlqE7JZvH-mzsSG_U6A 2840
openmsistream/services/install_service.py sha256=6juAuQstaQbSAY_OZOE6Hfxz26QJl3LT6vAZyKKZL_o 2271
openmsistream/services/linux_service_manager.py sha256=UiNQlIigXnlNWhGNxwhLNoaUWxAO78IZw41nmIdKpu8 9191
openmsistream/services/manage_service.py sha256=nfxgq64xbsAG52vy6FNncFJu11SN-WHnKrWT8YF8iuY 1416
openmsistream/services/service_manager_base.py sha256=XVqOaU10tj7OVmfMRWj2LsC8Sm0treIn0fiCFRxjsDg 22603
openmsistream/services/utilities.py sha256=CQ8BOxLQDI7F2jfkxYHIY4XrSg-e0eZaaGujRmpVci0 5508
openmsistream/services/windows_service_manager.py sha256=CVqNF4ZrFtS0Lr08HSh2fdtHTByDrXhYIolrN2tnmog 12100
openmsistream/services/examples/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
openmsistream/services/examples/runnable_example.py sha256=f39TOvH-YDfw1l4j4QIkfeEz3h4v90dADtcl1NyfnnE 1176
openmsistream/services/examples/script_example.py sha256=cFAsLoL5Xe4-6S4dtto7jF25uliDW0wImh9Z6jUBNBk 1285
openmsistream/tools/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
openmsistream/tools/provision_wrapper.py sha256=xJ5u_pRzp9-s6xVyNcxkO-wY85DHenPyogpxQIjp1Qs 6717
openmsistream/tools/undecryptable_messages/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
openmsistream/tools/undecryptable_messages/reproduce_undecryptable_messages.py sha256=dR11CFmaOLmK6GLclLkAAAGwEqmdnUeSKXdhdN3Eyu8 3114
openmsistream/utilities/__init__.py sha256=5J12pqs-kVVu1byw0dcaO9qVuo2EKJIuDME7v33WADw 379
openmsistream/utilities/argument_parsing.py sha256=dkazWFAFYgv6v5WakTpfH5Bk1Gpk3TIQi-cUvq0ennM 12008
openmsistream/utilities/config.py sha256=kzyzOsJx3tUiTnzQDkyFEh-K5zjn2idf6mLtUtYFJbo 1561
openmsistream/utilities/config_file_parser.py sha256=faMgUyWr3MzP4wfv1NtodQ-mJAYp7XpKfB41nmL_9RU 3543
openmsistream/utilities/controlled_processes_heartbeats.py sha256=UwCA002QDfnpt9Dy3jXCN1GMYKw9My0WsZyTaHfBSiI 5715
openmsistream/utilities/dataclass_table.py sha256=4vCofVjlWqb0n1MSDirUvLLEog5x-gMU_WaLum1iL98 22604
openmsistream/utilities/heartbeat_producibles.py sha256=rBwepIJYWxa5gzkJgk-HFgrqQRDaNwpsS2thAgWM_AA 3262
openmsistream-1.8.0.dist-info/LICENSE sha256=ixuiBLtpoK3iv89l7ylKkg9rs2GzF9ukPH7ynZYzK5s 35148
openmsistream-1.8.0.dist-info/METADATA sha256=A0WeC-bw0til201qt38TBE17Ho5JqmPasQYGixxYjzU 3699
openmsistream-1.8.0.dist-info/WHEEL sha256=G16H4A3IeoQmnOrYV4ueZGKSjhipXx8zc8nu9FGlvMA 92
openmsistream-1.8.0.dist-info/entry_points.txt sha256=s8tP87cGOzIYOlSAIi5OclAz51N8ow0offODd9ildgQ 745
openmsistream-1.8.0.dist-info/top_level.txt sha256=VlSRIYdr4rYvU23nRGJ87fGXX4R6Gdt793O6m-UvekI 14
openmsistream-1.8.0.dist-info/RECORD

top_level.txt

openmsistream

entry_points.txt

DataFileDownloadDirectory = openmsistream.data_file_io.actor.data_file_download_directory:main
DataFileUploadDirectory = openmsistream.data_file_io.actor.data_file_upload_directory:main
GirderUploadStreamProcessor = openmsistream.girder.girder_upload_stream_processor:main
InstallService = openmsistream.services.install_service:main
ManageService = openmsistream.services.manage_service:main
ProvisionNode = openmsistream.tools.provision_wrapper:main
ReproduceUndecryptableMessages = openmsistream.tools.undecryptable_messages.reproduce_undecryptable_messages:main
S3TransferStreamProcessor = openmsistream.s3_buckets.s3_transfer_stream_processor:main
UploadDataFile = openmsistream.data_file_io.entity.upload_data_file:main