ABEJA Datalake documentation

ABEJA Datalake library is SDK for python, which allows developers to create, get and delete datalake resources.

High level API

High level API is used following classes.

Usage

from abeja.datalake import Client

client = Client()

Low level API

Low level APIs are directly access the API endpoint.

Usage

from abeja.datalake import APIClient

api = APIClient()
channel = api.get_channel(organization_id, channel_id)

API Mapping

method path description
post /organizations/<organization_id>/channels APIClient.create_channel()
get /organizations/<organization_id>/channels APIClient.list_channels()
get /organizations/<organization_id>/channels/<channel_id> APIClient.get_channel()
patch /organizations/<organization_id>/channels/<channel_id> APIClient.patch_channel()
delete /organizations/<organization_id>/channels/<channel_id> APIClient.delete_channel()
get /organizations/<organization_id>/channels/<channel_id>/datasources APIClient.list_channel_datasources()
put /organizations/<organization_id>/channels/<channel_id>/datasources/<datasource_id> APIClient.put_channel_datasource()
delete /organizations/<organization_id>/channels/<channel_id>/datasources APIClient.delete_channel_datasource()
post /channels/ APIClient.get_channel_file_upload()
get /channels/<channel_id>/ APIClient.list_channel_files()
get /channels/<channel_id>/<file_id> APIClient.get_channel_file_download()
delete /channels/<channel_id>/<file_id> APIClient.delete_channel_file()
post /organizations/<organization_id>/buckets APIClient.create_bucket()
get /organizations/<organization_id>/buckets APIClient.list_buckets()
get /organizations/<organization_id>/buckets/<bucket_id> APIClient.get_bucket()
patch /organizations/<organization_id>/buckets/<bucket_id> APIClient.patch_bucket()
post /organizations/<organization_id>/buckets/<bucket_id>/archive APIClient.archive_bucket()
post /organizations/<organization_id>/buckets/<bucket_id>/unarchive APIClient.unarchive_bucket()
post /organizations/<organization_id>/buckets/<bucket_id>/files APIClient.upload_bucket_file()
post /organizations/<organization_id>/buckets/<bucket_id>/files APIClient.upload_bucket_files()
get /organizations/<organization_id>/buckets/<bucket_id>/files APIClient.list_bucket_files()
get /organizations/<organization_id>/buckets/<bucket_id>/files/<file_id> APIClient.get_bucket_file()