如何使用python正则表达式将路由密钥与RabbitMQ主题交换的绑定模式相匹配？

Question

我基本上是在RabbitMQ上工作。我正在编写一个python代码，其中我正在尝试查看在主题交换的情况下路由密钥是否与绑定模式匹配。我遇到了这个链接 - https://www.rabbitmq.com/tutorials/tutorial-five-java.html 它说 - “但是绑定键有两个重要的特殊情况：

* (star) can substitute for exactly one word.

# (hash) can substitute for zero or more words.

那么如何将消息的路由键与队列的绑定模式相匹配呢？例如，消息的路由键是“my.routing.key”，队列绑定到具有绑定模式的主题交换 - “my.#.*”。一般来说，我如何匹配这些字符串模式进行主题交换，最好是我希望使用python正则表达式。

Answer 1

我们使用此模式将RabbitMQ模式转换为正则表达式：

from typing import Pattern

def convert(pattern: str) -> Pattern:
    pattern = (
        pattern
        .replace('*', r'([^.]+)')
        .replace('.#', r'(\.[^.]+)*')
        .replace('#.', r'([^.]+\.)*')
    )
    return re.compile(f"^{pattern}$")

Answer 2

如果对你有帮助的话，我有一些Java代码

Pattern toRegex(String pattern) {
    final String word = "[a-z]+";

    // replace duplicate # (this makes things simpler)
    pattern = pattern.replaceAll("#(?:\\.#)+", "#");

    // replace *
    pattern = pattern.replaceAll("\\*", word);

    // replace #

    // lone #
    if ("#".equals(pattern)) return Pattern.compile("(?:" + word + "(?:\\." + word + ")*)?");

    pattern = pattern.replaceFirst("^#\\.", "(?:" + word + "\\.)*");
    pattern = pattern.replaceFirst("\\.#", "(?:\\." + word + ")*");

    // escape dots that aren't escapes already
    pattern = pattern.replaceAll("(?<!\\\\)\\.", "\\\\.");

    return Pattern.compile("^" + pattern + "$");
}

也许有人能把它翻译成python。

Answer 3

这是节点lib amqp匹配的一个几乎直接的端口：

import re

def amqp_match(key: str, pattern: str) -> bool:
    if key == pattern:
        return True
    replaced = pattern.replace(r'*', r'([^.]+)').replace(r'#', r'([^.]+.?)+')
    regex_string = f"^{replaced}$"
    match = re.search(regex_string, key)
    return match is not None