Py Brain.
Features
-
Process Streams
Process 1 S1(t) ---> Pp1.1(t) ---> Pp1.2(t) ---> Pp1.3(t) ---> Pp1.4(t) Process 2 S2(t) ---------------> Pp2.1(t) ----> Pp2.1(t) \ \ \ _\| Process 3 T1 (t) -----> Tp1.1 (t) ----> Tp1.1 (t) -
Gather Any data from stream by index (t)
from pulathisi import Brain def stream_process_1(context:Brain.Context): (<index>,<data>)=context.get_current_value('source_name') # Get latest stored value
-
Support for async process
-
Support for multiprocessing
-
In build Message queue
-
In build Brain Features
1. sum sources
@reactor.sum(name="sum_report", sources=['daily_summary', 'weekly_summary']) async def take_order_action(context: Reactor.Context, index, data): print(context.brain.reactor_time, index, data)
output
300000 300000 {'daily_summary': (300000, 'd300000'), 'weekly_summary': (299898, 'w299898')} 400000 400000 {'daily_summary': (400000, 'd400000'), 'weekly_summary': (399946, 'w399946')} 500000 500000 {'daily_summary': (500000, 'd500000'), 'weekly_summary': (499765, 'w499765')} 600000 600000 {'daily_summary': (600000, 'd600000'), 'weekly_summary': (599795, 'w599795')} 700000 700000 {'daily_summary': (700000, 'd700000'), 'weekly_summary': (699966, 'w699966')}
-
support for python development process
Release files for pulathisi 0.1.3
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| pulathisi-0.1.3.tar.gz | 5.4 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| pulathisi-0.1.3-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 11.9 kB
Release files / pulathisi-0.1.3.tar.gz
| Download URL | pulathisi-0.1.3.tar.gz |
|---|---|
| Size | 5.4 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
555d1e3d1c5113eaad2a2a7b7cd8a65581d16b398c99cd08ebe81c81054f96bf
|
|
BLAKE2b-256 checksum How to use checksums |
af18f006b52aab01269d408fd815421a864d68894d1815cf79e3a7b51598f30a
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/1.13.0 pkginfo/1.5.0.1 requests/2.18.4 setuptools/39.1.0 requests-toolbelt/0.9.1 tqdm/4.31.1 CPython/3.7.1
|
Release files / pulathisi-0.1.3-py3-none-any.whl
| Download URL | pulathisi-0.1.3-py3-none-any.whl |
|---|---|
| Size | 6.5 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
90e6ffc400a9bd577654c283b981bfebe14167de2ddc9bb5ccfc8ea149aeeea1
|
|
BLAKE2b-256 checksum How to use checksums |
eaa5fd770512496876c42ae10b6a43a38830660f51c9b6a5d067f0e656f57518
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/1.13.0 pkginfo/1.5.0.1 requests/2.18.4 setuptools/39.1.0 requests-toolbelt/0.9.1 tqdm/4.31.1 CPython/3.7.1
|