Skip to main content

A python schedulerplus client

Project description

example:

1.`export serverIp = xxx export serverPort = xxx`

2.schedulerplus_client.conf
```
[schedulerplus_client]
zk_url = localhost:2181
schedulerplus_url = localhost:8888
job_group = demogroup

```

3.demo_executor.py
```python
from schedulerplus.client.job_executor import JobExecutor
from schedulerplus.client.job_code_messages import *


class DemoExecutor(JobExecutor):

def execute(self, external_data):
print external_data
return SUCCESS_CODE, SUCCESS_MESSAGE
```


4.web_main.py
```python
import cherrypy
from schedulerplus.client.config import Config
Config.instance().load("xxx")

from schedulerplus.client.job_dispatcher import JobDispatcher
from schedulerplus.client.job_register import JobRegister

from demo.demo_executor import DemoExecutor


class JobDispatchController(object):
job_dispatcher = JobDispatcher()

@cherrypy.expose
@cherrypy.tools.json_in()
def dispatch(self):
form = cherrypy.request.json
self.job_dispatcher.dispatch(form)


if __name__ == "__main__":
JobRegister.instance().register("demo", DemoExecutor())
cherrypy.quickstart(JobDispatchController())
```

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

schedulerplus-client-0.0.16.tar.gz (5.9 kB view details)

Uploaded Source

File details

Details for the file schedulerplus-client-0.0.16.tar.gz.

File metadata

File hashes

Hashes for schedulerplus-client-0.0.16.tar.gz
Algorithm Hash digest
SHA256 b8c2109c0db160a2333c1227704c942f123b896e0e34ff66b2eb39d5f63db886
MD5 44bb7cb6087689d9ceee0a37b2ee7f43
BLAKE2b-256 ab9b8828bde6f0ee1420d0bb731ffd0f815bcf885276d954fd00b7cba2e9cb2a

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page