from clique_connector import Connector

connector = Connector('127.0.0.1')

# Request a virtual machine
machine = await connector.create_machine(
    'some-random-machine', # Machine name
    'ubuntu-16.04', # Image name
    1, # CPU
    512, # Memory in MB
    128, # Disc in GB
    'your-public-ssh-key-as-string') # Public SSH key

# Response with a virtual machine
def callback(channel_close, name, cpu, mem, disc, pkey):
    return dict(host='127.0.0.1',
                username='root')

# Create listener
channel_close, observable = connector.wait_for_machines(callback)

# Start listening
machines = await observable \
    .take(3) # Create only three machines

# Clean up by closing channel
channel_close()