Skip to main content

Send new file notifications

Project description

youvegotdata

Uses RabbitMQ to send new file notifications, with the ultimate purpose of getting the file metadata into the Data Inventory Database.

The "producer" youvegotdata.py will usually be called by the CIRA data ingest scripts when a new file is added to the CIRA data stores, and will send a message through RabbitMQ to the consumers with the file's metadata.

Message "consumers" will be running to receive the file metadata and insert it into the database. It is expected that multiple consumers process will be accepting messages in RabbitMQ's "fair dispatch" configuration. A given notification will be received by one consumer.

Installing youvegotdata

This module requires Python 3.8 or greater. It is deployed to PyPi, so it can be installed with:

pip install youvegotdata

Which will install the ygd CLI command in your current Python environment.

Running youvegotdata.py as ygd

Create the ~/.config/youvegotdata/ directory if it does not already exist. Create a config.ini file in this directory that looks like:

[Settings]
RMQ_HOST = <host of the RabbitMQ server>

[Data-store-mappings]
# The list of common Ceph IPs for every Ceph data store
# A dictionary of lists in Python format
CEPH_IPS = {"name": ["IP", "IP", "IP"], "name2": ["IP", "IP", "IP"],}

And fill it in with the RabbitMQ server's host name, and the IP address mappings across different Linux versions for the Ceph data stores.

Run the code with:

ygd [-h] [-v] [-p PRODUCT] [-r VERSION] [-s START_TIME] [-e END_TIME] [-l LENGTH] [-c CHECKSUM] [-t CHECKSUM_TYPE] filepath

Run this with the -h (--help) argument to see the available flagged arguments.

This will usually be run with just the filepath argument. An example is:

ygd /full/path/to/local/file/data_file.hdf

If run from a local repository of this project.

The filepath file must exist on the local machine.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

youvegotdata-1.1.1.tar.gz (11.2 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

youvegotdata-1.1.1-py3-none-any.whl (6.1 kB view details)

Uploaded Python 3

File details

Details for the file youvegotdata-1.1.1.tar.gz.

File metadata

  • Download URL: youvegotdata-1.1.1.tar.gz
  • Upload date:
  • Size: 11.2 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/6.1.0 CPython/3.13.12

File hashes

Hashes for youvegotdata-1.1.1.tar.gz
Algorithm Hash digest
SHA256 76215c0890248c624efb943890367a5e63ba2db527f554dcbf524e1623caa8ad
MD5 8803b905244a30ab4b3fb0dc3ff278e4
BLAKE2b-256 5c58f8b7b4ec6477e93160bee2526570f9cf2329789b7fd2286158c83702ba8b

See more details on using hashes here.

Provenance

The following attestation bundles were made for youvegotdata-1.1.1.tar.gz:

Publisher: package-and-publish.yaml on CIRA-GEOIPS/youvegotdata

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file youvegotdata-1.1.1-py3-none-any.whl.

File metadata

  • Download URL: youvegotdata-1.1.1-py3-none-any.whl
  • Upload date:
  • Size: 6.1 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/6.1.0 CPython/3.13.12

File hashes

Hashes for youvegotdata-1.1.1-py3-none-any.whl
Algorithm Hash digest
SHA256 4f0cc404e0c4fde5ba4d733f7355c7c04083d295e97c6c2829dc844662376c0f
MD5 1295800ec70a77a8cc9abb62bd736ffa
BLAKE2b-256 99f4b346b2e6d7ae89cfecd1d2927d7021638dda8927e1001cdb968d9b1e57a2

See more details on using hashes here.

Provenance

The following attestation bundles were made for youvegotdata-1.1.1-py3-none-any.whl:

Publisher: package-and-publish.yaml on CIRA-GEOIPS/youvegotdata

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page