Merge pull request #165 from digital-stars/master

Добавлен пример Streaming, добавлена функция удаления всех тегов для streaming

Author: python273

examples/README.md

@@ -15,5 +15,6 @@
 * [Получение аудиозаписей (VkAudio)](./get_all_audio.py)
 * [Составление клавиатуры для бота группы (VkKeyboard)](./keyboard.py)
 * [Получение большого кол-ва объектов (VkTools)](./get_full_wall.py)
+* [Работа с Streaming](./streaming.py)
 * [Работа с VkRequestsPool](./requests_pool.py)
 * [Работа с прокси и использование таймаутов](./proxies_timeout_retries.py)

examples/streaming.py

@@ -0,0 +1,26 @@
+# -*- coding: utf-8 -*-
+import vk_api
+from vk_api.streaming import VkStreaming
+
+
+def main():
+    """ Пример использования streaming
+	    https://vk.com/dev/streaming_api_docs
+    """
+    vk = vk_api.VkApi(token=<Сервисный ключ доступа>)
+    streaming = VkStreaming(vk)
+
+    streaming.delete_all_rules()
+
+    streaming.add_rule("квартира Москва", "Квартиры")
+    streaming.add_rule("купить гараж", "Гаражи")
+
+    for event in streaming.listen():
+        tags = '|'.join(event['tags'])
+        print("Теги: " + tags)
+        print("Запись: " + event['event_url'])
+        print("Текст: " + event['text'])
+        print("_____________________________________________________")
+
+if __name__ == '__main__':
+	main()

vk_api/streaming.py

@@ -92,6 +92,10 @@ def delete_rule(self, tag):
             return True
         elif response['code'] == 400:
             raise VkStreamingError(response['error'])
+ 
+    def delete_all_rules(self):
+        for item in self.get_rules():
+            self.delete_rule(item['tag'])
 
     def listen(self):
         """ Слушать сервер """