DataPipelines¶
This section documents the DataPipelinesApi client from openapi_client.api.data_pipelines_api. The content is generated automatically and updates when new methods are added.
Client¶
To use this API client:
import certifi
import boto3
from openapi_client.amorphic_api_client import AmorphicApiClient
from openapi_client.api.data_pipelines_api import DataPipelinesApi
ssm = boto3.client('ssm')
api_gw_url = ssm.get_parameter(Name='adp/amorphic/config/apigwurl', WithDecryption=False)['Parameter']['Value'] # String type; use WithDecryption=True for SecureString
role_id = ssm.get_parameter(Name='adp/amorphic/config/roleid', WithDecryption=False)['Parameter']['Value'] # String type; use WithDecryption=True for SecureString
client = AmorphicApiClient.create_with_auth(
host=api_gw_url,
role_id=role_id,
ssl_ca_cert=certifi.where(),
ssm_parameter='adp/amorphic/config/pattoken'
)
api = DataPipelinesApi(client)
Available Methods¶
- create_data_pipeline
- delete_data_pipeline
- generate_data_pipeline_node_logs
- get_data_pipeline_details
- get_data_pipeline_execution_details
- get_data_pipeline_file_load_manifest
- get_data_pipeline_node_logs
- list_data_pipeline_executions
- list_data_pipelines
- stop_data_pipeline_execution
- trigger_data_pipeline_execution
- update_data_pipeline