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.1a66.tar.gz (36.6 kB view details)

Uploaded Source

Built Distribution

File details

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

File metadata

File hashes

Hashes for datajunction_reflection-0.0.1a66.tar.gz
Algorithm Hash digest
SHA256 a5b4a602f77c70115c7ab96366e09d4582c70e80556d790c4d8f2cc934fc85b8
MD5 915011f290cb3680900830ebe048580b
BLAKE2b-256 dc374115698b32a936aaf2d81884cffc289bb4610ead76ffd05a0cbb2b912f13

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for datajunction_reflection-0.0.1a66-py3-none-any.whl
Algorithm Hash digest
SHA256 3d2d3940fd64ca6de250edb517449f277c03e2a22e4dc46604c32b203c5382f3
MD5 ee088c61cddbb6c5127b4a6751148a31
BLAKE2b-256 7f08e5d738be54834907e2ff736a5c85c3b8ebbde652a4a713a22414bb4c3905

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