我们如何通过 api 为 lambda 函数更新或创建新的 MSK 触发器

问题描述

我正在尝试通过 API 向列表添加主题来更新现有的 MSK 触发我的 lambda 函数。如果无法进行编辑，我也愿意创建新的 MSK 触发器。

这个新的触发器将通过另一个拥有自己事件的 lambda 函数添​​加到现有的 lambda 中。

有人可以指导我吗：

1. 是否可以通过 API 编辑现有的 MSK 触发器。
2. 或者，是否可以通过 API 添加和附加新的 MSK 触发器？

尝试挖掘文档： https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/lambda.html#Lambda.Client.update_function_event_invoke_config https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/Lambda.html#putFunctionEventInvokeConfig-property

代码：

Public Class Form1

    Dim MyCollection As New Collection

    Private Sub Form1_Load(sender As Object,e As EventArgs) Handles Me.Load
        'Populate your collection here from your csv by declaring a new
        'person for each row of your file,and then adding it to the 
        'collection.
    End Sub

    Private Sub ComboBox1_SelectedValueChanged(sender As Object,e As EventArgs) Handles ComboBox1.SelectedValueChanged
        Search_For_Name()
    End Sub

    Private Sub ComboBox2_SelectedValueChanged(sender As Object,e As EventArgs) Handles ComboBox2.SelectedValueChanged
        Search_For_Name()
    End Sub

    Private Sub Search_For_Name()
        For Each P As Person In MyCollection
            If P.ComboBox1Value = ComboBox1.Text And P.ComboBox2Value = ComboBox2.Text Then
                TextBox1.Text = P.Name
                Exit For
            End If
        Next
    End Sub

End Class

解决方法

Python - Boto3

您可以使用 update_event_source mapping 方法更新触发器。

您可以使用 create_event_source mapping 方法创建触发器。

Javascript - AWS 开发工具包

您可以使用 UpdateEventSourceMappingCommand 类更新触发器。

您可以使用 CreateEventSourceMappingCommand 类创建触发器。

以下是 AWS 文档“将 Lambda 与 Amazon MSK 结合使用”。 https://docs.aws.amazon.com/lambda/latest/dg/with-msk.html

我希望这可以帮助您解决问题。