我正在尝试从一个有2列的表A中编写一个查询: ID , STATUS 状态可以是PROCESSING, NOTPROCESSED, FAILED, SUCCESS 当成功处理一条记录时,将在数据库中创建一条状态为PROCESSED且ID与前一条NOTPROCESSED记录相同的新记录。数据库中的示例记录如下: 1 NOTPROCESSED1 PROCESSED
3 NO
我在使用MySQL并将一个独特的行返回到线程时遇到了一些困难。我想要它,所以线程将从表中搜索一行,其中位(见下面)为false,并且只返回一行。但是,我不希望其他线程返回相同的结果,如果可能存在相同结果返回到线程的竞争条件;因为线程随后将在这个结果的后面执行大量的处理,我不希望重复。id是自动递增的。我有一个多线程Ruby应用程序,可以读取、更新和插入表中的行。FROM table WHERE bit =FALSE LIMIT 1 FOR UPDATE
但是每个线程都返
有一个应用程序(不是我的)从Kafka读取消息,对它们进行一些处理,并将记录存储在数据库中。我用Java编写了一个程序,它以给定的速率将消息写入队列。现在,它通过在测试运行结束时查询数据库来进行简单的性能测量,以确保记录in = records out。但是,我想将其扩展为定期检查队列,以查看应用程序尚未处理的挂起消息的数量,以及是否正在备份它。我想我可以在Zookeeper中检查