# Run
## Hosts
```sh
python3 create_host.py
# send a test message with the RabbitMQ CLI
# https://www.rabbitmq.com/management-cli.html
rabbitmqadmin publish exchange=amq.default routing_key=test payload="Hello, world from RabbitMQ CLI"
# delete the queue `colabo.flow.host.node`
rabbitmqadmin delete queue name=colabo.flow.host.node
# delete all the messages in the `colabo.flow.host.node` queue
rabbitmqadmin purge queue name=colabo.flow.host.node
rabbitmqadmin purge queue name=colabo.flow.host.terra-python
rabbitmqadmin purge queue name=colabo.flow.host.heartbeat
cd /Users/mprinc/data/development/colabo-zontik/colabo/src/services/puzzles/flow/go
python3 create_host_terra.py
```
# Clients
```sh
cd /Users/mprinc/data/development/colabo-zontik/colabo/src/services/puzzles/flow/go
# sending a task request by python client
python3 create_client_terra.py
```
# Messages
```sh
# delete all the messages in the `colabo.flow.host.node` queue
rabbitmqadmin purge queue name=colabo.flow.host.node
```
## Heartbeat
```sh
# heartbeat for discovering python test host with a single task: `com.welcometerra.video.ffmpeg-multiple`
rabbitmqadmin publish exchange=amq.default routing_key=colabo.flow.host.heartbeat payload='{"id": "ColaboFlow-msg:371f4180-5c92-11ed-bc66-96ba02116486", "type": "HEARTBEAT", "requestId": "ColaboFlow-request:371f42f2-5c92-11ed-bc66-96ba02116486", "sender": "host-python-1", "replyTo": null, "proxies": [], "msgReplyChainIds": [], "msg": ["node host with tasks: ['com.welcometerra.video.ffmpeg-multiple']"], "extension": {"id": 2, "queueHost": "colabo.flow.host.python", "language": "PYTHON", "taskIds": ["com.welcometerra.video.ffmpeg-multiple"]}}'
```
Here is the full message:
```json
{
"id": "ColaboFlow-msg:371f4180-5c92-11ed-bc66-96ba02116486",
"type": "HEARTBEAT",
"requestId": "ColaboFlow-request:371f42f2-5c92-11ed-bc66-96ba02116486",
"sender": "host-python-1",
"replyTo": null,
"proxies": [],
"msgReplyChainIds": [],
"msg": ["node host with tasks: ['com.welcometerra.video.ffmpeg - multiple']"
],
"extension": {
"id": 2,
"queueHost": "colabo.flow.host.python",
"language": "PYTHON",
"taskIds": ["com.welcometerra.video.ffmpeg-multiple"]
}
}
```
## process_video
```json
{
"userId": 16,
"videoId": 49,
"videoFileLocalPath": "/var/folders/f5/s2lwsbwx34728zbv9vd91f4w0000gn/T/tmpzz4ykin9.mp4",
"first_name": "Sasha",
"email": "mprinc@gmail.com",
"username": "mprinc",
"task_context": {
"processId": 1,
"userId": 16,
"userName": "mprinc",
"videoId": 49,
"videoName": "ALWAYS BE SILENT IN FIVE SITUATIONS _ APJ Abdul Kalam Quotes _ Life Quotes - Quotation & Motivation.mp4",
"name": "process_video",
"id": 1
},
"videoToAudio": false
}
```
Raw data
{
"_id": null,
"home_page": "https://github.com/Cha-OS/",
"name": "colabo-flow.s-go",
"maintainer": "",
"docs_url": null,
"requires_python": "",
"maintainer_email": "",
"keywords": "colabo,RabbitMQ,flow,colaboflow,go,process,workflow",
"author": "ChaOS",
"author_email": "chaos.ngo@gmail.com",
"download_url": "https://files.pythonhosted.org/packages/c8/7a/00e9c1cdb174baf9b26273bf564178662e56477fa7c5c2bae9dc8c1ee567/colabo_flow.s_go-0.5.4.tar.gz",
"platform": null,
"description": "# Run\n\n## Hosts\n\n```sh\npython3 create_host.py\n\n# send a test message with the RabbitMQ CLI\n# https://www.rabbitmq.com/management-cli.html\nrabbitmqadmin publish exchange=amq.default routing_key=test payload=\"Hello, world from RabbitMQ CLI\"\n\n# delete the queue `colabo.flow.host.node`\nrabbitmqadmin delete queue name=colabo.flow.host.node\n\n# delete all the messages in the `colabo.flow.host.node` queue\nrabbitmqadmin purge queue name=colabo.flow.host.node\nrabbitmqadmin purge queue name=colabo.flow.host.terra-python\nrabbitmqadmin purge queue name=colabo.flow.host.heartbeat\n\ncd /Users/mprinc/data/development/colabo-zontik/colabo/src/services/puzzles/flow/go\n\npython3 create_host_terra.py\n```\n\n# Clients\n\n```sh\ncd /Users/mprinc/data/development/colabo-zontik/colabo/src/services/puzzles/flow/go\n\n# sending a task request by python client\npython3 create_client_terra.py\n```\n\n# Messages\n\n```sh\n# delete all the messages in the `colabo.flow.host.node` queue\nrabbitmqadmin purge queue name=colabo.flow.host.node\n```\n\n## Heartbeat\n\n```sh\n# heartbeat for discovering python test host with a single task: `com.welcometerra.video.ffmpeg-multiple`\nrabbitmqadmin publish exchange=amq.default routing_key=colabo.flow.host.heartbeat payload='{\"id\": \"ColaboFlow-msg:371f4180-5c92-11ed-bc66-96ba02116486\", \"type\": \"HEARTBEAT\", \"requestId\": \"ColaboFlow-request:371f42f2-5c92-11ed-bc66-96ba02116486\", \"sender\": \"host-python-1\", \"replyTo\": null, \"proxies\": [], \"msgReplyChainIds\": [], \"msg\": [\"node host with tasks: ['com.welcometerra.video.ffmpeg-multiple']\"], \"extension\": {\"id\": 2, \"queueHost\": \"colabo.flow.host.python\", \"language\": \"PYTHON\", \"taskIds\": [\"com.welcometerra.video.ffmpeg-multiple\"]}}'\n```\n\nHere is the full message:\n\n```json\n{\n\t\"id\": \"ColaboFlow-msg:371f4180-5c92-11ed-bc66-96ba02116486\",\n\t\"type\": \"HEARTBEAT\",\n\t\"requestId\": \"ColaboFlow-request:371f42f2-5c92-11ed-bc66-96ba02116486\",\n\t\"sender\": \"host-python-1\",\n\t\"replyTo\": null,\n\t\"proxies\": [],\n\t\"msgReplyChainIds\": [],\n\t\"msg\": [\"node host with tasks: ['com.welcometerra.video.ffmpeg - multiple']\"\n\t],\n\t\"extension\": {\n\t\t\"id\": 2,\n\t\t\"queueHost\": \"colabo.flow.host.python\",\n\t\t\"language\": \"PYTHON\",\n\t\t\"taskIds\": [\"com.welcometerra.video.ffmpeg-multiple\"]\n\t}\n}\n```\n\n## process_video\n\n```json\n{\n\t\"userId\": 16,\n\t\"videoId\": 49,\n\t\"videoFileLocalPath\": \"/var/folders/f5/s2lwsbwx34728zbv9vd91f4w0000gn/T/tmpzz4ykin9.mp4\",\n\t\"first_name\": \"Sasha\",\n\t\"email\": \"mprinc@gmail.com\",\n\t\"username\": \"mprinc\",\n\t\"task_context\": {\n\t\t\"processId\": 1,\n\t\t\"userId\": 16,\n\t\t\"userName\": \"mprinc\",\n\t\t\"videoId\": 49,\n\t\t\"videoName\": \"ALWAYS BE SILENT IN FIVE SITUATIONS _ APJ Abdul Kalam Quotes _ Life Quotes - Quotation & Motivation.mp4\",\n\t\t\"name\": \"process_video\",\n\t\t\"id\": 1\n\t},\n\t\"videoToAudio\": false\n}\n```\n",
"bugtrack_url": null,
"license": "MIT",
"summary": "A python ColaboFlow.Go (CF.Go) puzzle for supporting execution of workflow tasks over the RabbitMQ broker",
"version": "0.5.4",
"split_keywords": [
"colabo",
"rabbitmq",
"flow",
"colaboflow",
"go",
"process",
"workflow"
],
"urls": [
{
"comment_text": "",
"digests": {
"md5": "97d75bfcbefd035b265fd26c620e9054",
"sha256": "85192ccd576ad5bb370710bb34bed8aa96e45fafedbd1d0c3a7d450f63c8a20a"
},
"downloads": -1,
"filename": "colabo_flow.s_go-0.5.4.tar.gz",
"has_sig": false,
"md5_digest": "97d75bfcbefd035b265fd26c620e9054",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 22322,
"upload_time": "2023-01-02T11:04:26",
"upload_time_iso_8601": "2023-01-02T11:04:26.541148Z",
"url": "https://files.pythonhosted.org/packages/c8/7a/00e9c1cdb174baf9b26273bf564178662e56477fa7c5c2bae9dc8c1ee567/colabo_flow.s_go-0.5.4.tar.gz",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2023-01-02 11:04:26",
"github": false,
"gitlab": false,
"bitbucket": false,
"lcname": "colabo-flow.s-go"
}
JSON