0

我在 MySQL 中有一个事件，我想至少每 30 秒频繁运行一次。

它正在处理包含最近更新记录的队列表中的数据。有时我会收到大量更新。发生这种情况时，事件的运行时间可能比通常的 2-3 秒长。如果它在下一个计划时仍在运行，我希望下一个事件跳过执行。

我能想到的最好方法是创建一个“状态”表，在该表中我在进程开始时将特定键设置为 1，在完成时将其设置回 0。然后我会更改事件以检查当前状态。

我宁愿做一些比这更好的事情。有没有我完全缺少的功能？

我研究了全局变量，但根据文档，这些似乎只允许用于系统变量。

当前示例代码

这是我目前正在测试的示例代码。

acca_sync: BEGIN

  DECLARE EXIT HANDLER FOR SQLEXCEPTION BEGIN
    GET DIAGNOSTICS CONDITION 1 @sqlstate = RETURNED_SQLSTATE, 
    @errno = MYSQL_ERRNO, @text = MESSAGE_TEXT;
    SET @full_error = CONCAT("ERROR ", @errno, " (", @sqlstate, "): ", @text);
    call pa.log(concat("acca-acc_sync"," - Error - ", ifnull(@full_error,    "no error message")));
    UPDATE `acca`.`processing_state`
      SET `value` = 0
      WHERE `key` = 'acca_sync';
  END;

  call pa.log(CONCAT("Started acca_sync @ ", NOW()));
  SELECT `value`
    into @is_locked
    from `acca`.`processing_state`
    where `key` = 'acca_sync';

  IF @is_locked = 0 THEN
    UPDATE `acca`.`processing_state`
      SET `value` = 1
      WHERE `key` = 'acca_sync';
  ELSE
    CALL pa.log(CONCAT("acca_sync deferred due to active sync. @ ", NOW()));
    LEAVE acca_sync;
  END IF;

  call acca.event_sync();
  call pa.log(CONCAT("Completed acca_sync @ ", NOW()));

  UPDATE `acca`.`processing_state`
    SET `value` = 0
    WHERE `key` = 'acca_sync';

END

表锁定

根据评论，我想解释为什么我不使用表锁。我对表锁的经验是有限的，所以我希望以下内容是正确且有意义的。

源数据表

我有通知队列表中的更新的触发器。这些是我的源数据表，我从中读取数据以进行处理。

我的理解是，READ对这些表的锁定不会锁定刚刚读取的任何其他事件。如果我要使用WRITE锁，我会阻止对我当前不访问的任何行的任何更新。

目标数据表

我有多个数据源来处理不同事件中的数据。这些将在目标表中修改的行。可能有两个不同的事件同时运行写入同一个表，所以我不想人为地阻塞目标表

其他表

我可以创建一个假表，我只是为了设置然后检查锁的存在而拥有它。这似乎很荒谬，我宁愿创建一个带有我每次查询lock_key的列的单个表锁。is_locked

4

1 回答 1

0

您可以验证是否有任何事件正在运行：

 SELECT * 
 FROM performance_schema.threads 
 WHERE NAME LIKE '%event_worker%' 
      AND TYPE='FOREGROUND'

其他值得关注的有趣表格：

 SELECT * FROM information_schema.processlist
于 2019-05-30T03:17:18.737 回答