如何在AWS lambda中锁定共享变量以执行写操作

Question

我正在研究AWS lambda（无状态服务，您可以在其中运行代码）链接-什么是AWS lambda

在我的例子中，lambda正在运行1个服务，对于该服务，每个请求都必须执行写操作。每个请求绑定一个Id。

如果，请求是用相同的id绑定的。那么，应该按顺序处理。

所以，要做到这一点。我们必须锁定“id”。这样，我们就可以避免写操作冲突。

要做到这一点（我的研究）-

1. 创建具有1列Id的MySQL表，它是主键。意味着，您不能将1个id保留超过1次。

伪代码-

获取锁执行写操作释放锁

在这里，获取锁意味着-

如果，id已经存在，则等待，否则将id插入Mysql表

释放的意思是-

从MySQL中删除id

代码-

public void run() {

    String host = "AWS-RDS_HOST";
    String userName = "USERNAME";
    String password = "PASSWORD";
    String dbName = "DBNAME";
    Connection connection = createConnection(host, userName, password, dbName);
    Statement statement = null;

    try {
        statement = connection.createStatement();
    } catch(SQLException e) {
        throw new RuntimeException("Failed at taking statement");
    }

    // Aquire lock.
    while(true) {
        try {
            statement.executeUpdate("insert into locktable values('"+id+"');");
        } catch(SQLException e) {
            System.out.println("Failed in taking lock. Waiting for others to release the lock.");
            continue;
        }

        System.out.println("Yes...I took lock");
        break;
    }

    // Execute write operation
    System.out.println("Doing write operation");
    System.out.println("Wrtie operation completed");

    // Release lock.
    while(true) {
        try {
            statement.executeUpdate("DELETE from locktable where id='"+id+"'");
        } catch(SQLException e) {
            System.out.println("Failed to remove lock - " + id);
            continue;
        }
        System.out.println("Lock removed. Id - " + id);
        break;
    }
}`

问题-

1. 对于相同的id保持顺序行为，这种想法正确吗
2. 这个问题有没有更好的解决方案/想法
3. 如果你有一些关于这个问题的博客，请与我分享

Answer 1

部分回答您的问题：

我建议实现一个基于运动流的解决方案。复制自Kinesis Streams常见问题解答：

问：我应该什么时候使用Amazon Kinesis Streams，什么时候应该使用Amazon SQS？

我们建议Amazon Kinesis Streams用于具有类似以下要求的用例：

>

将相关记录路由到同一记录处理器[...]。例如，当给定密钥的所有记录都路由到同一记录处理器时，计数和聚合会更简单。

记录的排序。

这个想法是让一个Lambda充当Kinesis Producer，即处理传入html" target="_blank">请求并将记录放入Kinesis Streams。第二个Lambda将实现为Kinesis消费者（又名Kinesis Streams应用程序），它将从Kinesis Streams获取数据并执行您的写入操作。您可以根据您的id设置Kinesis Streams分区键。

请参见此SO答案。