Skip to main content

OSS Implementation of a DataJunction Reflection Service

Project description

DJ Reflection Service

The reflection service polls the DJ core service for all nodes with associated tables, whether source tables or materialized tables. For each node, it refreshes the node's schema based on the associated table's schema that it retrieves from the query service. It also retrieves the available partitions and the valid through timestamp of these tables and reflects them accordingly to DJ core.

This service uses a celery beat scheduler, with a configurable polling interval that defaults to once per hour and async tasks for each node's reflection.

Project details


Release history Release notifications | RSS feed

Download files

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

Source Distribution

datajunction_reflection-0.0.1a59.tar.gz (36.6 kB view details)

Uploaded Source

Built Distribution

File details

Details for the file datajunction_reflection-0.0.1a59.tar.gz.

File metadata

File hashes

Hashes for datajunction_reflection-0.0.1a59.tar.gz
Algorithm Hash digest
SHA256 2250daaf64601a250331afb92e2820e210f50e74dc57ebb4a473dce5db1dd13e
MD5 9c25d5797f0b7313a3076b7bca8ff363
BLAKE2b-256 ae52aab6b916b205d402d9f416a062fbc54b6f3cf7a7bc2f253ab21e788e1734

See more details on using hashes here.

File details

Details for the file datajunction_reflection-0.0.1a59-py3-none-any.whl.

File metadata

File hashes

Hashes for datajunction_reflection-0.0.1a59-py3-none-any.whl
Algorithm Hash digest
SHA256 3c649b9cb53a9d4c785f28b26a539bc5fc86d1a396d1c65dfec4750b1cb312d6
MD5 4827e1671999618d5de2c4cd0a8ba3a2
BLAKE2b-256 ae1d17ecc5e4721f40baec5b5bb1530fb75f4810437d7f21bc17784953bdc92f

See more details on using hashes here.

Supported by

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