(destinations)
Creates a destination given a name, workspace id, and a json blob containing the configuration for the source.
import airbyte_api
from airbyte_api import models
s = airbyte_api.AirbyteAPI(
security=models.Security(
basic_auth=models.SchemeBasicAuth(
password='',
username='',
),
),
)
res = s.destinations.create_destination(request=models.DestinationCreateRequest(
configuration=models.DestinationPgvector(
embedding=models.DestinationPgvectorFake(),
indexing=models.PostgresConnection(
credentials=models.DestinationPgvectorCredentials(
password='AIRBYTE_PASSWORD',
),
database='AIRBYTE_DATABASE',
host='AIRBYTE_ACCOUNT',
username='AIRBYTE_USER',
default_schema='AIRBYTE_SCHEMA',
port=5432,
),
processing=models.DestinationPgvectorProcessingConfigModel(
chunk_size=540943,
metadata_fields=[
'age',
],
text_fields=[
'users.*.name',
],
),
),
name='Postgres',
workspace_id='2155ae5a-de39-4808-af6a-16fe7b8b4ed2',
))
if res.destination_response is not None:
# handle response
pass
api.CreateDestinationResponse
Error Type |
Status Code |
Content Type |
errors.SDKError |
4XX, 5XX |
*/* |
Delete a Destination
import airbyte_api
from airbyte_api import api, models
s = airbyte_api.AirbyteAPI(
security=models.Security(
basic_auth=models.SchemeBasicAuth(
password='',
username='',
),
),
)
res = s.destinations.delete_destination(request=api.DeleteDestinationRequest(
destination_id='<value>',
))
if res is not None:
# handle response
pass
api.DeleteDestinationResponse
Error Type |
Status Code |
Content Type |
errors.SDKError |
4XX, 5XX |
*/* |
Get Destination details
import airbyte_api
from airbyte_api import api, models
s = airbyte_api.AirbyteAPI(
security=models.Security(
basic_auth=models.SchemeBasicAuth(
password='',
username='',
),
),
)
res = s.destinations.get_destination(request=api.GetDestinationRequest(
destination_id='<value>',
))
if res.destination_response is not None:
# handle response
pass
api.GetDestinationResponse
Error Type |
Status Code |
Content Type |
errors.SDKError |
4XX, 5XX |
*/* |
List destinations
import airbyte_api
from airbyte_api import api, models
s = airbyte_api.AirbyteAPI(
security=models.Security(
basic_auth=models.SchemeBasicAuth(
password='',
username='',
),
),
)
res = s.destinations.list_destinations(request=api.ListDestinationsRequest())
if res.destinations_response is not None:
# handle response
pass
api.ListDestinationsResponse
Error Type |
Status Code |
Content Type |
errors.SDKError |
4XX, 5XX |
*/* |
Update a Destination
import airbyte_api
from airbyte_api import api, models
s = airbyte_api.AirbyteAPI(
security=models.Security(
basic_auth=models.SchemeBasicAuth(
password='',
username='',
),
),
)
res = s.destinations.patch_destination(request=api.PatchDestinationRequest(
destination_id='<value>',
destination_patch_request=models.DestinationPatchRequest(
configuration=models.DestinationDuckdb(
destination_path='motherduck:',
),
name='My Destination',
),
))
if res.destination_response is not None:
# handle response
pass
api.PatchDestinationResponse
Error Type |
Status Code |
Content Type |
errors.SDKError |
4XX, 5XX |
*/* |
Update a Destination and fully overwrite it
import airbyte_api
from airbyte_api import api, models
s = airbyte_api.AirbyteAPI(
security=models.Security(
basic_auth=models.SchemeBasicAuth(
password='',
username='',
),
),
)
res = s.destinations.put_destination(request=api.PutDestinationRequest(
destination_id='<value>',
destination_put_request=models.DestinationPutRequest(
configuration=models.DestinationClickhouse(
database='<value>',
host='urban-receptor.org',
username='Kaylie_Terry',
),
name='My Destination',
),
))
if res.destination_response is not None:
# handle response
pass
api.PutDestinationResponse
Error Type |
Status Code |
Content Type |
errors.SDKError |
4XX, 5XX |
*/* |