0

我有一个激活数据管道的 Lambda 函数:

client.activate_pipeline(
    pipelineId='df-0680373LNPNFF73UDDD',
    parameterValues=[{'id':'myVariable','stringValue':'ok'}])

如何配置数据管道以在激活时接收参数值。例如,我想通过脚本参数将参数值“ok”传递给 ShellCommandActivity。

4

1 回答 1

1

AWS Datapipeline您创建参数/变量并在放置管道定义时定义其用法。
然后可以同时提供参数值,也可以在 的时间put-pipeline-defintion覆盖参数值pipeline-activation

如果参数声明为myVariable,则可以在管道对象内部将其引用为#{myVariable}

client.put_pipeline_definition(
        pipelineId='myPipeline',
        pipelineObjects=[
            {
                'id': 'CreateDirectory',
                "type" : "ShellCommandActivity",
                'name': 'CreateDirectory',
                'fields': [
                    {
                        'key': 'command',
                        'stringValue': 'mkdir #{myVariable}'
                    }
                ]
            }
        ],
        parameterObjects=[
            {
                'id': 'myVariable',
                'attributes': [
                    {
                        'key': 'description',
                        'stringValue': 'The directory to be created'
                    }
                ]
            }
        ],


client.activate_pipeline(
    pipelineId='df-0680373LNPNFF73UDDD',
    parameterValues=[{'id':'myVariable','stringValue':'ok'}])
于 2019-02-22T19:16:24.337 回答