已安装pika包，Ansible RabbitMQ查询插件仍报错求助

我来帮你搞定这个困扰！你遇到的问题其实是Ansible模块和Lookup插件的Python环境不一致导致的——虽然rabbitmq_publish模块能正常运行（说明你指定的Python3.7环境里有Pika），但rabbitmq lookup插件却没用到这个环境，所以才会报错说缺Pika。

下面是具体的解决步骤：

1. 统一Python解释器的全局设置 #

你之前只在rabbitmq_publish任务里定义了ansible_python_interpreter，但这个任务级别的变量只对该任务的模块生效，Lookup插件是在Ansible的控制进程上下文里运行的，它会读取全局级别的Python解释器配置。

同时还要修正debug模块的参数（你之前写的messages是错误的，debug模块需要用msg字段），修改后的playbook如下：

---
- hosts: localhost
  name: "something"
  vars:
    ansible_python_interpreter: /usr/local/bin/python3.7  # 全局设置，lookup插件也会使用这个解释器
  tasks:
    - name: Publish a message to a queue with headers
      rabbitmq_publish:
        url: "amqps://xx@roedeer.rmq.cloudamqp.com/xx"
        queue: 'RunningQueue'
        body: "Hello world from ansible module rabbitmq_publish"
        durable: yes
        content_type: "text/plain"
    - name: Get 2 messages off a queue and set a fact for re-use
      debug:
        msg: "{{ lookup('rabbitmq', url='amqps://xx@roedeer.rmq.cloudamqp.com/xx', queue='JobQueue') }}"

2. 验证指定Python环境的Pika安装 #

先确认你指定的Python3.7环境里确实装了Pika，执行这条命令：

/usr/local/bin/python3.7 -c "import pika; print(pika.__version__)"

如果这条命令能正常输出版本号，说明环境没问题；如果报错，就用这个Python解释器重新安装Pika：

/usr/local/bin/python3.7 -m pip install pika

为什么会出现这个差异？ #

简单给你理清楚逻辑：

• rabbitmq_publish是Ansible的模块，它运行在目标节点（这里就是你的localhost），任务级别的ansible_python_interpreter会强制这个模块使用你指定的Python环境。
• 而rabbitmq lookup插件是在你运行ansible-playbook的控制节点进程里直接执行的，它不会读取任务级别的Python解释器设置，只会用全局配置或者Ansible默认的Python（可能不是你装了Pika的3.7版本）。

按照上面的步骤调整后，应该就能解决这个报错了！

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