nephos.preprocessor.preprocess
index
/media/hdd/Essentials/Chapter_Kgp_WOrk/GSoC/projectnephos_gsoc18/GSoC18Nephos/nephos/preprocessor/preprocess.py

Contains the main preprocess class

 
Modules
       
os

 
Classes
       
builtins.object
PreprocessHandler

 
class PreprocessHandler(builtins.object)
    Class to init, load, add and process video streams
 
  Methods defined here:
__init__(self, scheduler)
Load settings and add preprocessing to scheduler.
 
Parameters
----------
scheduler
    type: Scheduler class
    default background job scheduler
add_to_scheduler(self)
Adds preprocessing job to class' scheduler.
 
Returns
-------

Static methods defined here:
display_tasks()
Prints the list of pending tasks
 
Returns
-------
init_preprocess_pipe()
Loads data from the database and passes it into the preprocessing pipe
 
Returns
-------
insert_task(orig_path, ip_addr)
Insert a new task into the "tasks" table
 
Parameters
-------
orig_path
    type: str
    original path to the recorded file
ip_addr
    type: str
    ip address of the channel of the recorded video
 
Returns
-------

Data descriptors defined here:
__dict__
dictionary for instance variables (if defined)
__weakref__
list of weak references to the object (if defined)

 
Data
        LOG = <logging.Logger object>
TSK_FAIL_INDEX = 7
TSK_ID_INDEX = 0
TSK_PATH_INDEX = 1
TSK_STAT_INDEX = 6
TSK_STORE_INDEX = 2
__upload_dir__ = '/home/thealpha/Nephos/processed'