Skip to content

Added produce_to decorator for multi queue producing

Latest
Compare
Choose a tag to compare
@Attumm Attumm released this 16 Aug 07:22
2986827

The decorated function should yield tuples of (queue_name, item_value).

    Example:
        @box.produce_to()
        def produce_multi(items):
            return items

        items = [
            ("foo1", "item1"),
            ("foo2", "item2"),
            ("foo3", "item3"),
            ("foo1", "item4"),
            ("foo2", "item5"),
            ("foo3", "item6"),
        ]
        produce_multi(items)

    In this example:
    - Each tuple in the `items` list represents a (queue, value) pair.
    - The first element of each tuple ("foo1", "foo2", "foo3") is the queue name.
    - The second element of each tuple ("item1", "item2", etc.) is the value to be sent to the queue.

    The decorator will process these items as follows:
    1. "item1" will be sent to the "foo1" queue
    2. "item2" will be sent to the "foo2" queue
    3. "item3" will be sent to the "foo3" queue
    4. "item4" will be sent to the "foo1" queue
    5. "item5" will be sent to the "foo2" queue
    6. "item6" will be sent to the "foo3" queue