ABEJA Datalake library is SDK for python, which allows developers to create, get and delete datalake resources.
High level API is used following classes.
from abeja.datalake import Client
client = Client()
Low level APIs are directly access the API endpoint.
from abeja.datalake import APIClient
api = APIClient()
channel = api.get_channel(organization_id, channel_id)
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() |