salt.modules.boto_datapipeline¶

Connection module for Amazon Data Pipeline

depends:

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