なんかキュー多すぎて、捨てるわけにもいかないしどうしたらいいの
@mei23@misskey.m544.net atsuchan.pageとmt.shc.kanagawa.jpですね、問題のリレーから切断したけど再試行キューがすごい溜まってて、新しいアクティビティを受信しても、raceconditionでキューに詰まれるから投稿がまともに入ってこない
@atsu1125@meisskey.one Mastodonはわからないけど、力技かキューを消すしかないんじゃないかしら
@mei23@misskey.m544.net なるほどです、該当のリレーのキューだけ消すことってできますか？ @noellabo@fedibird.com
@atsu1125 ActivityPub::ProcessingWorkerあたりで、条件判定してWorkerを正常終了させるようにすれば自然にキューが捌けるから、その手がいいかな。
問題は条件だ。toがrelay.shc.kanagawa.jpかrelay.misskey.cfになってるAnnounceでいいかな。これを正常終了させる。
@atsu1125 こんなん。
class ActivityPub::ProcessingWorker
include Sidekiq::Worker
include JsonLdHelper
sidekiq_options backtrace: true, retry: 8
def perform(account_id, body, delivered_to_account_id = nil)
json = body_to_json(body)
return if json['type']&.include?('Announce') && (json['to']&.include?('relay.shc.kanagawa.jp') || json['to']&.include?('relay.misskey.cf'))
実行してないから動くかわからんけど、だいたいこんな感じのコード。JsonLdHelperの行と、performのあとの2行ね。
あとは応用きかせたまい。
@noellabo@fedibird.com なんとかさばけました〜ありがとうございます
@noellabo@fedibird.com いえいえ、ハマってます…