如何从GetStream的SQS消息中获取已删除activity的verb？

当从SQS队列收到的删除消息中缺少verb字段时，你可以通过以下两种方式获取该字段，来更新基于verb的计数器：

方案1：通过Activity ID查询原活动详情 #

利用GetStream JavaScript SDK的client.activity.get()方法，通过deleted列表中的活动ID直接查询完整的活动数据，从中提取verb字段。

示例代码：

const stream = require('getstream');
const client = stream.connect('YOUR_API_KEY', 'YOUR_API_SECRET', 'YOUR_APP_ID');

// 假设从SQS消息中拿到的deleted活动ID
const deletedActivityId = '38f81366-847f-11e4-9c94-0cc47a024be0';

async function getVerbFromDeletedActivity(activityId) {
  try {
    const activity = await client.activity.get(activityId);
    return activity.verb;
  } catch (error) {
    console.error('获取活动详情失败:', error);
    // 处理错误，比如记录日志或使用默认值
    return null;
  }
}

// 调用方法获取verb
getVerbFromDeletedActivity(deletedActivityId).then(verb => {
  if (verb) {
    // 更新对应verb的计数器
    console.log(`更新计数器: ${verb}`);
  }
});

方案2：利用foreign_id关联查询 #

如果你的活动使用了foreign_id（如示例中deleted_foreign_ids里的内容），可以结合foreign_id和时间戳，通过client.activity.getForeignId()方法查询原活动：

示例代码：

// 从SQS消息的deleted_foreign_ids中拿到的foreign_id和时间戳
const [foreignId, timestamp] = ['your_foreign_id', '2014-12-15T17:20:37.263518+00:00'];

async function getVerbByForeignId(foreignId, timestamp) {
  try {
    const activity = await client.activity.getForeignId(foreignId, timestamp);
    return activity.verb;
  } catch (error) {
    console.error('通过foreign_id获取活动失败:', error);
    return null;
  }
}

// 调用方法
getVerbByForeignId(foreignId, timestamp).then(verb => {
  if (verb) {
    // 更新计数器逻辑
  }
});

注意事项 #

• 确保SDK版本为最新，避免方法兼容性问题
• 处理查询失败的情况，比如活动已被彻底删除，此时需要考虑计数器的回退逻辑或跳过更新
• 批量处理删除消息时，建议批量查询活动详情，减少API调用次数

内容的提问来源于stack exchange，提问作者Amirhossein Mahdinejad