awrns / awareness

>>> import awareness as a

>>> # Let's make a simple Component that does something with data.

>>> class AdderComponent(a.LocalComponent):
...     inputs = 2 # We'll take two numerical inputs
...     outputs = 1 # and produce one numerical output.
...
...     def run(self, input, progress_callback=None):
...         output = []
...         for item in input.items:
...             value1 = item[0] # The first of the two numerical inputs
...             value2 = item[1] # The second
...             output.append([value1 + value2]) # Let's just add them.
...         return a.Stream(output)
...

>>> # Now let's put it on the network using an Operator.

>>> operator = a.LocalOperator(b'192.168.1.2') # The IP address of this computer 
>>> operator.components.append(AdderComponent())

>>> # Now let's make another Operator on the same network.
>>> # You'll need to switch to a different computer now.

>>> operator2 = a.LocalOperator(b'192.168.1.3') # The IP address of this other computer
>>> # It should know about the other Operator that we created earlier on 192.168.1.2.
>>> operator2.remote_operators.append(a.RemoteOperator(b'192.168.1.2'))

>>> # Now, we'll make some 'examples' of data that our AdderComponent should be able to handle.

>>> example1 = [2, 2]
>>> result1 = [4]
>>> example2 = [3, 1]
>>> result2 = [4]
>>> example3 = [1, 1]
>>> result3 = [3]
>>> examples = a.Set(
...     a.Stream([example1, example2, example3]),
...     a.Stream([result1, result2, result3])
... )

>>> # Let's feed that to the new operator2 on 192.168.1.3.
>>> # It will research which Component on the network is best.
>>> # (The result should be our AdderComponent on 192.168.1.2.)

>>> suggestion = operator2.search(1, examples, 2)
>>> print(suggestion.operations)
[(b'192.168.1.2', 1600, 0, 0, 0)]

>>> # It knows that the AdderComponent is probably a good fit for our examples! Let's try it:

>>> result = suggestion.run(a.Stream([example1, example2, example3]))
>>> result = result.extract(0, 1) # Restrict the result to just one output for readability
>>> print(result.items)
[[4]
 [4]
 [3]]

>>> # That's very cool. Imagine how easy it might be to find solutions to computational problems
>>> # if all software was in the form of Components!