semvec/pypi-packages huggingface dataset:
HiveClients 1.0.2
链接hive数据库的程序,使用impala库

# 说明
这是一个链接hive数据库的程序,使用impala库

## 安装
使用pip安装：
bash
pip install HiveClients
 
### 联系我们
如果你有任何问题或建议，请联系我649898871@qq.com
nioflux-mq 0.0.1
A thread-safe message queue implementation.
Requires Python: >=3.10

# *NioFluxMQ*

*A thread-safe message queue implementation.*

## Installation

```bash
pip install -U nioflux-mq
```

```bash
uv add -U nioflux-mq
```

## Quick Start

1. Start a server

    ```bash
    python -m nioflux_mq.server
    ```

    ```
    PS D:\project\NioFluxMQ> py -m nioflux_mq.server
    [INFO] 2025-09-01 14:14:35,188 nioflux.mq : \
        _   __ _____                             
       / | / / ____/                             
      /  |/ / /___                               
     / /|  / ____/                               
    /_/ |_/_/                                    
    =0.0.0.0:26105=                              
    NioFluxMQServer started.  
    ```

2. Access MQ via clients

    1. Connect to a server

        ```python
        from nioflux_mq.client.client import NioFluxMQClient

        client = NioFluxMQClient(host='127.0.0.1', port=26105)
        ```

    2. Register a topic

        ```python
        client.register_topic('topic_0')
        ```

    3. Register a consumer

        ```python
        client.register_consumer('consumer_0')
        ```

    4. Sent a message to a topic

        ```python
        client.produce(b'message_0', 'topic_0', ttl=1)
        ```

    5. Consume a message

        ```python
        message = client.consume('consumer_0', 'topic_0').data
        client.advance('consumer_0', 'topic_0')
        ```

    6. Retreat the pointer if you missread some messages

        ```python
        client.retreat('consumer_0', 'topic_0')
        ```