aapl.py - actor

aapl.py

@ray.remote
class Comparator:
    def __init__(self):
        self.last_quote = None

    def append(self, event):
        payload = json.loads(event)  # parse event payload to json
        quote = payload[0]['price']  # extract AAPL quote
        if self.last_quote:
            if quote > self.last_quote:
                sink.append('AAPL is up')  # send to Slack
            elif quote < self.last_quote:
                sink.append('AAPL is down')  # send to Slack
        self.last_quote = quote

comparator = Comparator.remote()  # instantiate comparator actor
source.send_to(comparator)  # subscribe comparator to source