You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

如何用pymqi获取队列深度?调用inquire时遇MQRC_SELECTOR_NOT_FOR_TYPE错误

解决pymqi查询队列深度时的MQRC_SELECTOR_NOT_FOR_TYPE错误

这个错误的核心原因是:你使用的MQIA_CURRENT_Q_DEPTH选择器,不适用于当前操作的队列类型。

MQ的不同队列类型对查询选择器的支持不同,比如以下类型队列不支持查询当前队列深度:

  • 集群传输队列(MQQT_CLUSTER_TRANSMIT)
  • 模型队列(MQQT_MODEL)
  • 临时队列(MQQT_TEMPORARY)

解决步骤

  1. 先确认队列类型
    使用MQCA_Q_TYPE选择器查询当前队列的类型,代码示例:

    q_type = queue.inquire(pymqi.CMQC.MQCA_Q_TYPE)
    # 转成整数(部分pymqi版本返回字节串,需解码后转int)
    q_type_int = int(q_type.decode('utf-8'))
    

    对比MQ常量判断类型,比如本地队列(MQQT_LOCAL)是支持查询深度的。

  2. 仅对支持的队列类型查询深度
    只有当队列类型为本地队列、普通传输队列等支持的类型时,再调用MQIA_CURRENT_Q_DEPTH查询:

    if q_type_int == pymqi.CMQC.MQQT_LOCAL:
        depth = queue.inquire(pymqi.CMQC.MQIA_CURRENT_Q_DEPTH)
        print(f"队列深度: {depth}")
    else:
        print(f"队列类型 {q_type_int} 不支持查询当前深度")
    
  3. 特殊队列的深度查询替代方案
    如果是集群传输队列这类特殊队列,可以通过查询对应的系统统计队列,或者使用MQ的统计API(如PCF命令)来获取相关数据。

内容的提问来源于stack exchange,提问作者reut

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.06.30 14:27:43