Форум программистов, компьютерный форум CyberForum.ru

Python: Сети

Войти
Регистрация
Восстановить пароль
 
creonz
1 / 1 / 0
Регистрация: 29.05.2013
Сообщений: 24
#1

Коннектор к API используя AsyncIO, aiohttp - Python

21.05.2016, 14:39. Просмотров 527. Ответов 0
Метки нет (Все метки)

Py3.5.
Работаю с библиотекой, подключаюсь к api telegram. Получаю сообщения и отправляю их в обработку. Сообщения будут выполнять запросы к бд, поэтому время выполнения их будет разным, и подразумевалось что во время выполнения этого запроса будет выполняться получение новых сообщений. То есть работа основной сопрограммы по получению этих сообщений не будет тормозиться. Сейчас в качестве заглушки использую asyncio.sleep(10), и он тормозит выполнение полностью. В чем я ошибся?
Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
import asyncio
import aiohttp
import json
 
async def fetch(url, data=None, proxy=None):
    headers = {"content-type": "application/json"}
    async with aiohttp.ClientSession() as session:
        async with session.post(url, data=json.dumps(data), headers=headers) as response:
            if response.status == 200:
                print(await response.text())
                try:
                    jdata = await response.json()
                except (ValueError, AttributeError) as error:
                    LOG.error(error)
                else:
                    if jdata['ok']:
                        return jdata['result']
                    else:
                        LOG.error(jdata)
            else:
                print('ERRRR')
                print(await response.text())
 
def _todict(params, more=[]):
    return {key: value for key, value in params.items() if key not in ['self'] + more}
 
class telega(object):
 
    def __init__(self, token, offset = 0):
        self.token = token
        self.offset = offset
        self._runnable = True
 
    def _msgurl(self, method):
        return '{url}{token}/{method}'.format(
            url='https://api.telegram.org/bot',
            token=self.token,
            method=method)
 
    def _fileurl(self, method):
        return '{url}{token}/{method}'.format(
            url='https://api.telegram.org/file/bot',
            token=self.token,
            method=method)
 
    def message(func):
        def decorator(self, *args, **kwargs):
            url, data = func(self, *args, **kwargs)
            return fetch(url, data)
        return decorator
 
    @message
    def get_me(self):
        method = 'getMe'
        return self._msgurl(method), None
 
    @message
    def get_updates(self, offset=None, limit=100, timeout=30):
        method = 'getUpdates'
        data = _todict(locals())
        return self._msgurl(method), data
 
    @message
    def send_message(self, chat_id, text, **kwargs):
        method = 'sendMessage'
        data = _todict(locals())
        return self._msgurl(method), data
 
    async def processing(self, msg):
        await asyncio.sleep(10)
        await self.send_message(msg['message']['chat']['id'], 'sleep 10 sec stop')
 
    async def check_updates(self):
        print(await self.get_me())
        while self._runnable:
            upd = await self.get_updates(self.offset+1)
            for msg in upd:
                await self.send_message(msg['message']['chat']['id'], msg['message']['text'])
                await self.processing(msg)
                self.offset = msg['update_id']
 
    def run(self):
        loop = asyncio.get_event_loop()
        loop.run_until_complete(self.check_updates())
        loop.run_forever()
 
if __name__ == '__main__':
    bot = telega('token')
    bot.run()
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
21.05.2016, 14:39     Коннектор к API используя AsyncIO, aiohttp
Посмотрите здесь:

Как можно запустить прогу, не используя функцию Shell, а используя API функцию? Visual Basic
Получение информации из другой программы используя API C++ Builder
Email socket API Python
Delphi Авторизация в VK.com не используя API
PHP Пишу сайт используя API поиска авиабилетов
C (Си) Архивация файлов, используя библиотеку Win32 API
Редактировать текст используя ms Word API с++ C++
Python С чего начать разбираться с Asyncio?
Python Кто-нибудь уже использует aiohttp/muffin etc. ?
Выйти из петли в run_forever() [asyncio] Python
Supervisor,Mozilla Circus, cron. Aiohttp сервис Python
Asyncio корректное завершение в случае непредвиденной остановки программы Python

Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2017, vBulletin Solutions, Inc.
Рейтинг@Mail.ru