semvec/pypi-packages huggingface dataset:
vahfka 2.0.0
Kafka-Vahfka

vahfka

The vahfka library simplifies Kafka interaction by providing convenient abstractions for both producing and consuming messages. It seamlessly integrates with the kafka-python library and offers additional features for asynchronous message sending and context management.

Installation

You can install the vahfka library using pip:
```bash
pip install vahfka
```

Usage

Initializing the Kafka Producer:
```python
from vahfka import KafkaProducerWithCallbacks
```

# Create a KafkaProducerWithCallbacks instance
```python
kafka_producer = KafkaProducerWithCallbacks(bootstrap_servers='localhost:9092')
```

Sending Messages:

Synchronous Message Sending:
```python
# Send a message synchronously
kafka_producer.send_message(topic='example_topic', message={'key': 'value'})
```

Asynchronous Message Sending:

```python
# Send a message asynchronously
kafka_producer.send_message_async(topic='example_topic', message={'key': 'value'})
Kafka Consumer Wrapper:
from vahfka import KafkaConsumerWrapper

# Create a KafkaConsumerWrapper instance
kafka_consumer = KafkaConsumerWrapper(
    bootstrap_servers='localhost:9092',
    group_id='my-group',
    topics=['example_topic']
)

```

```python
Consuming Messages:
# Consume messages from Kafka topic
messages = kafka_consumer.consume_messages()
print(messages)
```

```python
Context Management:
# Use the KafkaProducerWithCallbacks as a context manager
with KafkaProducerWithCallbacks(bootstrap_servers='localhost:9092') as producer:
    producer.send_message(topic='example_topic', message={'key': 'value'})

```


Example
```python
from vahfka import KafkaProducerWithCallbacks, KafkaConsumerWrapper

# Initialize KafkaProducerWithCallbacks and KafkaConsumerWrapper instances
kafka_producer = KafkaProducerWithCallbacks(bootstrap_servers='localhost:9092')
kafka_consumer = KafkaConsumerWrapper(
    bootstrap_servers='localhost:9092',
    group_id='my-group',
    topics=['example_topic']
)

# Send a message
kafka_producer.send_message(topic='example_topic', message={'key': 'value'})

# Consume messages
messages = kafka_consumer.consume_messages()
print(messages)

```

For questions, issues, or contributions, please visit the https://gitlab.com/magmam/egov
pyenvs 0.0.2
A small .env parser
Requires Python: >=3.8


Highly Minimalistic .env File Wrapper

### Sample:

Suppose you have the following .env file:

```sh
ACCESS_KEY = jriofesdjxifocjewsayiofdlcj
```

Parsing it may look something like this:
```py
>>> import os
>>> from pyenvs import load_dotenv
>>> load_dotenv()
>>> os.environ["ACCESS_KEY"]
jriofesdjxifocjewsayiofdlcj
```
pyenvs-stupidjohanna 0.0.1
A small .env parser
Requires Python: >=3.8


Highly Minimalistic .env File Wrapper

### Sample:

Suppose you have the following .env file:

```sh
ACCESS_KEY = jriofesdjxifocjewsayiofdlcj
```

Parsing it may look something like this:
```py
>>> import os
>>> from pyenvs import load_dotenv
>>> load_dotenv()
>>> os.environ["ACCESS_KEY"]
jriofesdjxifocjewsayiofdlcj
```
pyrotest 0.0.2
pyroTest package
Requires Python: >=3.8

# pyroTest Guidelines

### Precondition:

**System Requirements:**

    Operating System : Ubuntu Server 18.04.5 LTS.
    Processor (CPU)  : 1 or 2 CPU cores minimum. 64-bit CPU required, Intel or AMD.
    Memory (RAM)     : 4GB RAM minimum
    HDD (Storage)    : 30GB disk size minimum.

**Packages Requirements:**

There are certain preconditions which we need to take into consideration before start running 
the automated regression suite. We need to install the below packages to satisfy the precondition requirements. 


**For Ubuntu & Debian Machines**

### How to Install Chrome Driver:

    wget https://chromedriver.storage.googleapis.com/2.41/chromedriver_linux64.zip
    unzip chromedriver_linux64.zip
    sudo mv chromedriver /usr/bin/chromedriver
    sudo chown root:root /usr/bin/chromedriver
    sudo chmod +x /usr/bin/chromedriver
    sudo rm -fr chromedriver_linux64.zip

### How to Install Gecko Driver:

    wget https://github.com/mozilla/geckodriver/releases/download/v0.26.0/geckodriver-v0.26.0-linux64.tar.gz
    tar xvzf geckodriver-v0.26.0-linux64.tar.gz
    sudo chmod 777 geckodriver
    sudo mv geckodriver /usr/bin/

### How to install firefox Driver:
     wget https://ftp.mozilla.org/pub/firefox/releases/66.0.3/linux-x86_64/en-US/firefox-66.0.3.tar.bz2
     tar -xjf firefox-66.0.3.tar.bz2
     sudo rm -rf /opt/firefox
     sudo mv firefox/ /opt
     sudo mv /usr/bin/firefox /usr/bin/firefox_old
     sudo ln -s /opt/firefox/firefox /usr/bin/firefox

### How to create Virtual Environment:

## How to create 3-site topology

### Precondition to create 3-site topology in KVM

Before creating topology we need to create KVM hypervisor, We can create KVM hypervisor in below mentioned ways
    1. Create a Hypervisor in Virtual Box/ESXi in private infrastructure
    2. Create a Hypervisor in Cloud infrastructure using GCP 

As of now we have automated the topology creation in GCP environment for 3-site.