Apeman DAL service client SDK
Project description
This library enables you to interact with DAL service to save and load your data
publish:
python setup.py sdist bdist_wheel
twine upload --repository-url https://test.pypi.org/legacy/ dist/*
install: pip install apeman-dal-client==0.1.0
How to use
export apeman_dal_server_addr='localhost:9090'
Create Datafeed
from apeman.dal.tsdb.enum import DataAmount, DataType
from apeman.dal.tsdb import ApemanDalTsdbClient
from apeman.dal.tsdb import ColumnDefinitionBuilder, CreateDatafeedRequestBuilder, \
UniqueKeyBuilder
# build create datafeed request
tag = ColumnDefinitionBuilder() \
.set_name(name='tag_nae') \
.set_non_null(non_null=True) \
.set_type(data_type=DataType.TEXT) \
.set_limit(limit=100).build()
field = ColumnDefinitionBuilder() \
.set_name(name='field_name') \
.set_non_null(non_null=True) \
.set_type(data_type=DataType.TEXT) \
.set_limit(limit=100).build()
unique_key = UniqueKeyBuilder().add(name='tag_name').build()
unique_key_2 = UniqueKeyBuilder().add(name='field_name').build()
data_amount = DataAmount.SMALL
create_datafeed_request = CreateDatafeedRequestBuilder() \
.set_name(name='test') \
.add_tag(tag=tag) \
.add_field(field=field) \
.add_unique_key(unique_key=unique_key) \
.add_unique_key(unique_key=unique_key_2) \
.set_data_amount(data_amount=data_amount) \
.build()
client = ApemanDalTsdbClient()
# create datafeed
client.create_datafeed(request=create_datafeed_request)
#
Delete Datafeed
from apeman.dal.tsdb import ApemanDalTsdbClient
client = ApemanDalTsdbClient()
# delete datafeed
client.delete_datafeed(datafeed='test')
Get Datafeed
from apeman.dal.tsdb import ApemanDalTsdbClient
client = ApemanDalTsdbClient()
# delete datafeed
client.get_datafeed(datafeed='test')
List Datafeed
from apeman.dal.tsdb import ApemanDalTsdbClient
client = ApemanDalTsdbClient()
# delete datafeed
client.list_datafeed(query_filter='')
Put Data
from apeman.dal.tsdb import ApemanDalTsdbClient
from apeman.dal.tsdb.enum import DataType
from apeman.dal.tsdb.proto_builder import TabularDataBuilder, ColumnMetaBuilder, TupleBuilder, ValBuilder
client = ApemanDalTsdbClient()
column_a = ColumnMetaBuilder() \
.set_name(name='column_a') \
.set_data_type(data_type=DataType.TEXT) \
.build()
column_b = ColumnMetaBuilder() \
.set_name(name='column_b') \
.set_data_type(data_type=DataType.BIGINT) \
.build()
tuple_a = TupleBuilder() \
.add_val(val = ValBuilder().set_i32(1000).build()) \
.add_val(val = ValBuilder().set_i32(1000).build()) \
.add_val(val = ValBuilder().set_i32(1000).build()) \
.add_val(val = ValBuilder().set_i32(1000).build()) \
.build()
tuple_b = TupleBuilder() \
.add_val(val = ValBuilder().set_i32(1000).build()) \
.add_val(val = ValBuilder().set_i32(1000).build()) \
.add_val(val = ValBuilder().set_i32(1000).build()) \
.add_val(val = ValBuilder().set_i32(1000).build()) \
.build()
data = TabularDataBuilder() \
.add_column(column=column_a) \
.add_column(column=column_b) \
.add_tuple(tuple=tuple_a) \
.add_tuple(tuple=tuple_b) \
.build()
client.put_data(datafeed='test', data=data)
Get Data
from apeman.dal.tsdb import ApemanDalTsdbClient
from apeman.dal.tsdb.enum import DataType
from apeman.dal.tsdb.proto_builder import TabularDataBuilder, ColumnMetaBuilder, \
GetDataRequestBuilder
client = ApemanDalTsdbClient()
column_a = ColumnMetaBuilder() \
.set_name(name='column_a') \
.set_data_type(DataType.TEXT) \
.build()
column_b = ColumnMetaBuilder() \
.set_name(name='column_b') \
.set_data_type(DataType.TEXT) \
.build()
request = GetDataRequestBuilder() \
.add_column(column=column_a) \
.add_column(column_b) \
.set_datafeed(datafeed='test') \
.set_where(where='') \
.set_group_by(group_by='') \
.set_having(having='') \
.set_order_by(order_by='') \
.set_offset(offset=0) \
.set_limit(limit=100) \
.build()
data = TabularDataBuilder() \
.add_column(column_a) \
.add_column(column_b).build()
client.get_data(request=request)
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
Built Distribution
Close
Hashes for apeman-dal-client-0.0.8rc5.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 93d965630221b6408e84e26d040e3b361aad00fa3473308f5fd9b298e936c938 |
|
MD5 | d5e99ff81f8a24f7081e074c256b650a |
|
BLAKE2b-256 | 5bed758b1ab1ed6908feab6b0eccddcf3a9ff654ca619d6ad7c37179eceed88f |
Close
Hashes for apeman_dal_client-0.0.8rc5-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | ede8e897e2344f1881b82c00fa25656148041afe07da640a74ddcdd706aabd61 |
|
MD5 | e5fb0885bd51c0f3480bf5232749116d |
|
BLAKE2b-256 | ee1f10c3b551deebd2982354eac2418655af4db77d30ad0b4e76b86c18cc181e |