Motoma

running = False

try:
    # We first connect to the bridge running on port 18293.
    bridge_server = socket.socket()
    bridge_server.connect(('my.public.server.addr', 18293))
    print("Connected to Bridge")

    # Then we wait for incoming data.
    data = bridge_server.recv(1024)

Motoma

motoma@arbiter$ beanstalkd -d -b -l 0.0.0.0 -p 11300

Motoma

#!/usr/bin/env python                                                                                                   

import os
import pickle
import time

import beanstalkc

# Images are stored locally in 'images', and moved to 'original' when 
# they have been passed to the queue

Motoma

#!/usr/bin/env python                                                                                                   

import os
import pickle
import random
import sys

import beanstalkc

# Use *'s sparingly!

Motoma

#!/usr/bin/env python                                                                                                   

import os
import pickle

import beanstalkc

OUTPUT_DIRECTORY = 'processed'

MQHOST = 'arbiter'

Motoma

motoma@filter-0$ python filter.py

Motoma

motoma@filter-1$ python filter.py

Motoma

motoma@filter-n$ python filter.py

Motoma

motoma@database$ python database.py

Motoma

motoma@queuer-0$ python queuer.py