触发器操作

更新时间：2024-07-05

各接口的请求参数和响应参数说明请参考触发器操作。

触发器为函数BRN级别，函数不同的版本、别名函数均可关联触发器。因此在以下的增删改查示例中，函数相关的标识符均使用函数BRN而非函数名。

根据后端实现的不同，函数计算触发器可以分成relation和eventSourceMapping两种类型，对应两种API和SDK调用方法，具体分类如下表格所示。在使用SDK时需要根据触发器的类型调用不同的方法。

类型	触发器种类
relation	DuerOS、BOS、HTTP、定时任务、CDN、DuEdge
eventSourceMapping	百度消息服务

获取触发器列表

如下代码用于获取函数relation触发器列表：

                Javascript
                
                var options = {
    'FunctionBrn': 'brn:bce:cfc:su:7c54a6e14823a11c9f9f5345952ac336:function:test:$LATEST'
}

cfcClient.listRelations(options).then(response => {
    console.log(response.body)
})

如下代码用于获取函数eventsourceMapping触发器列表：

                Javascript
                
                var options = {
    'FunctionName': 'brn:bce:cfc:su:7c54a6e14823a11c9f9f5345952ac336:function:test:$LATEST'
}

cfcClient.listEventSourceMappings(options).then(response => {
    console.log(response.data)
})

创建触发器

如下代码用于创建HTTP触发器：

                Javascript
                
            

                // 不同触发器的Source和Data字值不同，具体请参考接口文档。
var body = {
    'Target': 'brn:bce:cfc:su:7c54a6e14823a11c9f9f5345952ac336:function:test:$LATEST', // 函数 BRN
    'Source': 'cfc-http-trigger/v1/CFCAPI', // 触发源类型为http
    'Data': {                               // http触发器的配置参数
        'AuthType': 'anonymous',
        'Method': 'GET,POST', 
        'ResourcePath': '/helloworld'
    }
}

cfcClient.createRelation(body).then(response => {
    console.log(response.data)
}).catch(err => {
    console.error(err)
})
            

如下代码用于创建百度消息服务触发器：

                Javascript
                
            

                var body = {
    'BatchSize': 100,
    'Enabled': true,
    'EventSourceBrn': '7c54a6e14823a11c9f9f5345952ac336__test_topic',
    'FunctionName': 'brn:bce:cfc:bj:7c54a6e14823a11c9f9f5345952ac336:function:test:$LATEST',
    'Source': 'kafka',
    'StartingPosition': 'TRIM_HORIZON'
}

cfcClient.createEventSourceMapping(body).then(response => {
    console.log(response.body)
}).catch(err => {
    console.error(err)
})
            

更新触发器

如下代码用于更新HTTP触发器：

                Javascript
                
            

                var updateBody = {
    // RelationId 触发器的唯一标识，从 listRelations 的返回结果中获取
    'RelationId': 'brn:bce:cfc-http-trigger:su:7c54a6e14823a11c9f9f5345952ac336:8b1ddba7fec6f3e1506cad8e5a5512fb/cfc/GET,POST/test/helloworld',
    'Target': 'brn:bce:cfc:su:7c54a6e14823a11c9f9f5345952ac336:function:test:$LATEST', // 函数 BRN
    'Source': 'cfc-http-trigger/v1/CFCAPI', // 触发源类型为http
    'Data': {                               // http触发器的配置参数
        'AuthType': 'anonymous',
        'Method': 'GET,POST,PUT', 
        'ResourcePath': '/hellocfc'
    }
};

cfcClient.updateRelation(updateBody).then(response => {
    console.log(response.body)
}).catch(err => {
    console.log(err)
})
            

如下代码用于更新百度消息服务触发器：

                Javascript
                
            

                var updateBody = {
    'BatchSize': 150,
    'FunctionName': 'brn:bce:cfc:su:7c54a6e14823a11c9f9f5345952ac336:function:test:$LATEST'
}

// esmId 为触发器唯一标识，从listEventSourceMappings的返回结果中获取
cfcClient.updateEventSourceMapping(esmId, updateBody).then(response => {
    console.log(response.body)
}).catch(err => {
    console.error(err)
})
            

删除触发器

如下代码用于删除HTTP触发器：

                Javascript
                
            

                var deleteOptions = {
    'Target': 'brn:bce:cfc:su:7c54a6e14823a11c9f9f5345952ac336:function:test:$LATEST',
    'Source':'cfc-http-trigger/v1/CFCAPI',
    'RelationId':'brn:bce:cfc-http-trigger:su:7c54a6e14823a11c9f9f5345952ac336:8b1ddba7fec6f3e1506cad8e5a5512fb/cfc/GET,POST/test/helloworld'
}

cfcClient.deleteRelation(deleteOptions).catch(err => {
    console.error(err)
})
            

如下代码用于删除百度消息服务触发器：

                Javascript
                
                // esmId 为列表接口返回的触发器 id
cfcClient.deleteEventSourceMapping(esmId).catch(err => {
    console.error(err)
})

别名操作

版本变更记录

百度智能云

函数计算 CFC