Skip to content

R
Read_from_Kairos_Component
Commit 6b814467 authored by Akshay G's avatar Akshay G
Browse files
Options

Bug Fix

parent 4f7c01a3
Show whitespace changes
Inline Side-by-side
Showing with 17 additions and 5 deletions
README.md
View file @ 6b814467
# Multipipeline Kairos Read Component for Batch Pipelines # Multipipeline Kairos Read Component for Batch Pipelines
## Pass in the configurations: ### Pass in the configurations:
```python ```python
{ {
"kairosdb_url": "http://192.168.0.207:8080", "kairosdb_url": "http://192.168.0.207:8080",
...@@ -11,3 +11,13 @@ ...@@ -11,3 +11,13 @@
"shared_volume": "/mnt" "shared_volume": "/mnt"
} }
``` ```
### Run Docker Container mounting the same directory to which the csv file is to be written
```
docker run -v /mnt:/mnt -e config='{"kairosdb_url": "http://192.168.0.207:8080",' \
'"metric_name": "ilens.live_data.raw",' \
'"tag_hierarchy": "site_153$dept_1006$line_220$equipment_1258$tag_5790",' \
'"start_absolute": "01/10/2020 00:00:00",' \
'"end_absolute": "30/11/2020 00:00:00",' \
'"shared_volume": "/mnt"}' batch-multi-karios-read-component:v0.1
```
\ No newline at end of file
scripts/common/config_parser.py
View file @ 6b814467
...@@ -4,10 +4,12 @@ import sys ...@@ -4,10 +4,12 @@ import sys
import json import json
import yaml import yaml
# os.environ['config'] = '{"kairosdb_url": "http://192.168.0.207:8080","metric_name": "ilens.live_data.raw",' \ # os.environ['config'] = '{"kairosdb_url": "http://192.168.0.207:8080",' \
# '"tag_hierarchy": "site_153$dept_1006$line_220$equipment_1258$tag_5790", "start_absolute": ' \ # '"metric_name": "ilens.live_data.raw",' \
# '"01/10/2020 ' \ # '"tag_hierarchy": "site_153$dept_1006$line_220$equipment_1258$tag_5790",' \
# '00:00:00","end_absolute": "30/11/2020 00:00:00","shared_volume": "/mnt"}' # '"start_absolute": "01/10/2020 00:00:00",' \
# '"end_absolute": "30/11/2020 00:00:00",' \
# '"shared_volume": "/mnt"}'
config_path = os.path.join(os.getcwd(), "conf", "configuration.yml") config_path = os.path.join(os.getcwd(), "conf", "configuration.yml")
if os.path.exists(config_path): if os.path.exists(config_path):
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment