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
1 maintainer
Metadata
1 maintainer
Release files for vdk-ingest-http 0.2.1156222304
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| vdk-ingest-http-0.2.1156222304.tar.gz | 7.5 kB | Details |
Release files / vdk-ingest-http-0.2.1156222304.tar.gz
| Download URL | vdk-ingest-http-0.2.1156222304.tar.gz |
|---|---|
| Size | 7.5 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
a48d7f7a9b94f83fd2b66f2d524b24f409355900a8390ea54e3ba2307bcb9d32
|
|
BLAKE2b-256 checksum How to use checksums |
567c62d3af3bdbee389665fb3e1ffb2e488e993e74a907b0ef5f43ef3a54a5ba
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/4.0.2 CPython/3.10.13
|
