subscriptions.py 文件源码

def add_subscribers(self, subscribers):
        if type(subscribers) != list:
            subscribers = [subscribers]

        for subscriber in subscribers:
            if not self._is_subscriber_exists(subscriber):
                self.bulk.find(
                    {'username': self.username}
                ).update({'$push': {'subscribers': subscriber}})

            else:
                msg = 'Subscriber {} already exists with group {}!'
                print(msg.format(subscriber['spy'], subscriber['group']))
        try:
            self.bulk.execute()
        except InvalidOperation as e:
            print(e)