DataPipeline / Client / put_pipeline_definition

put_pipeline_definition

DataPipeline.Client.put_pipeline_definition(**kwargs)

Adds tasks, schedules, and preconditions to the specified pipeline. You can use PutPipelineDefinition to populate a new pipeline.

PutPipelineDefinition also validates the configuration as it adds it to the pipeline. Changes to the pipeline are saved unless one of the following three validation errors exists in the pipeline.

• An object is missing a name or identifier field.

• A string or reference field is empty.

• The number of objects in the pipeline exceeds the maximum allowed objects.

• The pipeline is in a FINISHED state.

Pipeline object definitions are passed to the PutPipelineDefinition action and returned by the GetPipelineDefinition action.

See also: AWS API Documentation

Request Syntax

response = client.put_pipeline_definition(
    pipelineId='string',
    pipelineObjects=[
        {
            'id': 'string',
            'name': 'string',
            'fields': [
                {
                    'key': 'string',
                    'stringValue': 'string',
                    'refValue': 'string'
                },
            ]
        },
    ],
    parameterObjects=[
        {
            'id': 'string',
            'attributes': [
                {
                    'key': 'string',
                    'stringValue': 'string'
                },
            ]
        },
    ],
    parameterValues=[
        {
            'id': 'string',
            'stringValue': 'string'
        },
    ]
)

Parameters:

• pipelineId (string) –

  [REQUIRED]

  The ID of the pipeline.

• pipelineObjects (list) –

  [REQUIRED]

  The objects that define the pipeline. These objects overwrite the existing pipeline definition.

  • (dict) –

    Contains information about a pipeline object. This can be a logical, physical, or physical attempt pipeline object. The complete set of components of a pipeline defines the pipeline.

    • id (string) – [REQUIRED]

      The ID of the object.

    • name (string) – [REQUIRED]

      The name of the object.

    • fields (list) – [REQUIRED]

      Key-value pairs that define the properties of the object.

      • (dict) –

        A key-value pair that describes a property of a pipeline object. The value is specified as either a string value ( StringValue ) or a reference to another object ( RefValue ) but not as both.

        • key (string) – [REQUIRED]

          The field identifier.

        • stringValue (string) –

          The field value, expressed as a String.

        • refValue (string) –

          The field value, expressed as the identifier of another object.

• parameterObjects (list) –

  The parameter objects used with the pipeline.

  • (dict) –

    Contains information about a parameter object.

    • id (string) – [REQUIRED]

      The ID of the parameter object.

    • attributes (list) – [REQUIRED]

      The attributes of the parameter object.

      • (dict) –

        The attributes allowed or specified with a parameter object.

        • key (string) – [REQUIRED]

          The field identifier.

        • stringValue (string) – [REQUIRED]

          The field value, expressed as a String.

• parameterValues (list) –

  The parameter values used with the pipeline.

  • (dict) –

    A value or list of parameter values.

    • id (string) – [REQUIRED]

      The ID of the parameter value.

    • stringValue (string) – [REQUIRED]

      The field value, expressed as a String.

Return type:

dict

Returns:

Response Syntax

{
    'validationErrors': [
        {
            'id': 'string',
            'errors': [
                'string',
            ]
        },
    ],
    'validationWarnings': [
        {
            'id': 'string',
            'warnings': [
                'string',
            ]
        },
    ],
    'errored': True|False
}

Response Structure

• (dict) –

  Contains the output of PutPipelineDefinition.

  • validationErrors (list) –

    The validation errors that are associated with the objects defined in pipelineObjects .

    • (dict) –

      Defines a validation error. Validation errors prevent pipeline activation. The set of validation errors that can be returned are defined by AWS Data Pipeline.

      • id (string) –

        The identifier of the object that contains the validation error.

      • errors (list) –

        A description of the validation error.

        • (string) –

  • validationWarnings (list) –

    The validation warnings that are associated with the objects defined in pipelineObjects .

    • (dict) –

      Defines a validation warning. Validation warnings do not prevent pipeline activation. The set of validation warnings that can be returned are defined by AWS Data Pipeline.

      • id (string) –

        The identifier of the object that contains the validation warning.

      • warnings (list) –

        A description of the validation warning.

        • (string) –

  • errored (boolean) –

    Indicates whether there were validation errors, and the pipeline definition is stored but cannot be activated until you correct the pipeline and call PutPipelineDefinition to commit the corrected pipeline.

Exceptions

• DataPipeline.Client.exceptions.InternalServiceError

• DataPipeline.Client.exceptions.InvalidRequestException

• DataPipeline.Client.exceptions.PipelineNotFoundException

• DataPipeline.Client.exceptions.PipelineDeletedException