Fluxo

Simple data flow with execution in separate threads and easy scheduling configuration.

Installation

To use the fluxo library, you can install it using the pip command. Make sure you have Python and pip installed before proceeding.

pip install fluxo

How to Use

1 - Create a folder in the project root:

First, create a folder named python_files at the root of your project. This folder will contain your Python files.

2 - Create a Python file within the python_files folder:

Now, create a Python file named fluxo1.py within the python_files folder. This is where you can write your Python code.

3 - Write the code:

Write the following code in the fluxo1.py file to create a basic flow with a task:

python_files/flow1.py:

from fluxo import Flow, Task, Minutes

interval = Minutes(1, 30).format()
flow = Flow(name='My Flow 1', interval=interval)

@Task('My Task 1', flow=flow)
async def My_func():
    print('My_func executed!')

4 - Finally, start the program with the command below:

python -m fluxo.init_schedule

5 - In another terminal, run the command below to start the web server::

python -m fluxo.init_server

6 - Open browser:

http://127.0.0.1:8080