Connection module for Amazon Data Pipeline
New in version 2016.3.0.
boto3
salt.modules.boto_datapipeline.
activate_pipeline
(pipeline_id, region=None, key=None, keyid=None, profile=None)¶Start processing pipeline tasks. This function is idempotent.
CLI example:
salt myminion boto_datapipeline.activate_pipeline my_pipeline_id
salt.modules.boto_datapipeline.
create_pipeline
(name, unique_id, description='', region=None, key=None, keyid=None, profile=None)¶Create a new, empty pipeline. This function is idempotent.
CLI example:
salt myminion boto_datapipeline.create_pipeline my_name my_unique_id
salt.modules.boto_datapipeline.
delete_pipeline
(pipeline_id, region=None, key=None, keyid=None, profile=None)¶Delete a pipeline, its pipeline definition, and its run history. This function is idempotent.
CLI example:
salt myminion boto_datapipeline.delete_pipeline my_pipeline_id
salt.modules.boto_datapipeline.
describe_pipelines
(pipeline_ids, region=None, key=None, keyid=None, profile=None)¶Retrieve metadata about one or more pipelines.
CLI example:
salt myminion boto_datapipeline.describe_pipelines ['my_pipeline_id']
salt.modules.boto_datapipeline.
get_pipeline_definition
(pipeline_id, version='latest', region=None, key=None, keyid=None, profile=None)¶Get the definition of the specified pipeline.
CLI example:
salt myminion boto_datapipeline.get_pipeline_definition my_pipeline_id
salt.modules.boto_datapipeline.
list_pipelines
(region=None, key=None, keyid=None, profile=None)¶Get a list of pipeline ids and names for all pipelines.
CLI Example:
salt myminion boto_datapipeline.list_pipelines profile=myprofile
salt.modules.boto_datapipeline.
pipeline_id_from_name
(name, region=None, key=None, keyid=None, profile=None)¶Get the pipeline id, if it exists, for the given name.
CLI example:
salt myminion boto_datapipeline.pipeline_id_from_name my_pipeline_name
salt.modules.boto_datapipeline.
put_pipeline_definition
(pipeline_id, pipeline_objects, parameter_objects=None, parameter_values=None, region=None, key=None, keyid=None, profile=None)¶Add tasks, schedules, and preconditions to the specified pipeline. This function is idempotent and will replace an existing definition.
CLI example:
salt myminion boto_datapipeline.put_pipeline_definition my_pipeline_id my_pipeline_objects