From 0c6d6956aa350637ac515d2c161f39fba08cedf9 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Tue, 17 Sep 2019 12:00:45 -0500 Subject: [PATCH] housekeeping/documentation --- transport/common.py | 2 +- transport/mongo.py | 6 ++++++ transport/queue.py | 7 +++++++ transport/s3.py | 6 ++++++ 4 files changed, 20 insertions(+), 1 deletion(-) diff --git a/transport/common.py b/transport/common.py index c55141b..993a961 100644 --- a/transport/common.py +++ b/transport/common.py @@ -6,7 +6,7 @@ This module is designed to serve as a wrapper to a set of supported data stores - couchdb - mongodb - Files (character delimited) - - Queues (RabbmitMq) + - Queues (Rabbmitmq) - Session (Flask) - s3 The supported operations are read/write and providing meta data to the calling code diff --git a/transport/mongo.py b/transport/mongo.py index 51b6e28..48235e8 100644 --- a/transport/mongo.py +++ b/transport/mongo.py @@ -1,3 +1,9 @@ +""" +Data Transport - 1.0 +Steve L. Nyemba, The Phi Technology LLC + +This file is a wrapper around mongodb for reading/writing content against a mongodb server and executing views (mapreduce) +""" from pymongo import MongoClient # from transport import Reader,Writer from common import Reader, Writer diff --git a/transport/queue.py b/transport/queue.py index 64c770a..1199687 100644 --- a/transport/queue.py +++ b/transport/queue.py @@ -1,3 +1,10 @@ +""" +Data Transport - 1.0 +Steve L. Nyemba, The Phi Technology LLC + +This file is a wrapper around rabbitmq server for reading and writing content to a queue (exchange) + +""" import pika from datetime import datetime import re diff --git a/transport/s3.py b/transport/s3.py index 9b117db..12412d5 100644 --- a/transport/s3.py +++ b/transport/s3.py @@ -1,3 +1,9 @@ +""" +Data Transport - 1.0 +Steve L. Nyemba, The Phi Technology LLC + +This file is a wrapper around s3 bucket provided by AWS for reading and writing content +""" from datetime import datetime import boto import botocore