# cobweb

**Repository Path**: mirrors/cobweb

## Basic Information

- **Project Name**: cobweb
- **Description**: Distributed task execution system
- **Primary Language**: Python
- **License**: GPL-2.0
- **Default Branch**: master
- **Homepage**: https://www.oschina.net/p/cobweb
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2017-04-02
- **Last Updated**: 2025-10-25

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

cobweb
======
a distributed task execution system

* easy to dispatch task script and autoreload
* multi-process task model
* multi-thread task running
* support task parameter router



            pidFile = "cw.pid"
            hostName = "TestHost"
            logFile = "cobweb.log"
            logLevel = 0 # if logLevel > 0 then run as a daemon

            taskList = [
                {
                    "dictString" : "ThankYouForChoosingMoreTV",
                    "indexUrl" : "http://127.0.0.1:8080/cobweb/index",
                    "downloadUrl" : "http://127.0.0.1:8080/cobweb/download",
                    "taskFreq" : 5, # Option
                    "indexFreq" : 15, # Option        
                    "taskUrl" : "http://127.0.0.1:8080/cobweb/parameter",  # Option
                    "resultUrl" : "http://127.0.0.1:8080/cobweb/result", # Option
                }
            ]

            ############################

            import Cobweb.Process
            import Cobweb.Thread
            import Cobweb.Utiles

            Logger = Cobweb.Utiles.Logger(logFile, logLevel)
            Daemon = Cobweb.Process.Daemon(pidFile, Logger)

            try:
                if 0 == logLevel:
                    import time
                    for task in taskList:
                        Cobweb.Thread.Tasks(task, hostName, Logger).start()
                    while True: time.sleep(9999)
                else:
                    for task in taskList:
                        Daemon.start(Cobweb.Thread.Tasks(task, hostName, Logger))
            except (IOError,EOFError,KeyboardInterrupt):
                Daemon.killAll()
                exit(0)