welcome to beamism
Project description
# beamism
beamism is a tiny framework to run apache beam based software.
### Installation
```
pip install beamism
```
### Quick Start(Examples)
```
# run locally
python examples/wordcount_streaming.py
# deploy to Google Cloud Dataflow
python examples/wordcount_streaming.py --runner DataflowRunner --project {YOUR_PROJECT}--setup_file {ABSOLUTE_PATH_TO_SETUP.PY} --requirements_file {ABSOLUTE_PATH_TO_REQUIREMENTS.TXT} --temp_location {GCP_STORAGE_PATH} --staging_location {GCP_STORAGE_PATH}
```
※ This module is inspired by [Apache Beam](https://github.com/apache/beam), and some codes are modified based on it.
beamism is a tiny framework to run apache beam based software.
### Installation
```
pip install beamism
```
### Quick Start(Examples)
```
# run locally
python examples/wordcount_streaming.py
# deploy to Google Cloud Dataflow
python examples/wordcount_streaming.py --runner DataflowRunner --project {YOUR_PROJECT}--setup_file {ABSOLUTE_PATH_TO_SETUP.PY} --requirements_file {ABSOLUTE_PATH_TO_REQUIREMENTS.TXT} --temp_location {GCP_STORAGE_PATH} --staging_location {GCP_STORAGE_PATH}
```
※ This module is inspired by [Apache Beam](https://github.com/apache/beam), and some codes are modified based on it.
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
beamism-0.1.0.tar.gz
(4.3 kB
view hashes)
