vdk-ingest-http

VDK-INGEST-HTTP Plugin

This plugin provides functionality to ingest data over http.

Usage

To use the plugin, just install it, and set the method attribute of send_object_for_ingestion(), and send_tabular_data_for_ingestion() functions to "http".

Example:

def run(job_input: IJobInput):
    # Do something to get data for ingestion
    payload = get_some_data()

    # Ingest the data
    job_input.send_object_for_ingestion(payload=payload,
                                        destination_table="aa_test_table",
                                        method="http",
                                        target="http://example.com/data-source"
                                        )

The above example shows how to ingest json data. In this case, there are three arguments that are required: payload, method and target. This would be fixed in the future, so that only payload would be required.
The payload needs to be a json object, and should contain the destination_table inside, using the @table key. For example:

{
    "@table": "destination_table_name",
    "column1": "value1",
    "column2": "value2",
    "column3": "value3",
}

The method attribute needs to be provided for the time being.
The target attribute should specify the url endpoint, where the data will be ingested.

Testing

To develop or test locally (from the current directory)

# install dev and test dependencies
pip install -r requirements
# install the plugin in editable mode
pip install -e .
# run the tests
pytest

Metadata

Release files for vdk-ingest-http 0.1.367189843

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for vdk-ingest-http 0.1.367189843
File	Size	Uploaded
vdk-ingest-http-0.1.367189843.tar.gz	3.5 kB	Sep 8, 2021	Details

Release files / vdk-ingest-http-0.1.367189843.tar.gz

Download URL	vdk-ingest-http-0.1.367189843.tar.gz
Size	3.5 kB
Tags	Source
SHA-256 checksum How to use checksums	`2d58940cc3df32cf86187b106c207c521b6f05cc9229ad465a255d3a9cdd62b7`
BLAKE2b-256 checksum How to use checksums	`d0a11a383dde894469b43c15af5524619c12cd517f563e330e854f232fe30b7d`
Upload date	Sep 8, 2021
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/3.4.2 importlib_metadata/4.8.1 pkginfo/1.7.1 requests/2.26.0 requests-toolbelt/0.9.1 tqdm/4.62.2 CPython/3.7.11`