Форум программистов, компьютерный форум, киберфорум
Наши страницы

Python: Сети

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

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

21.05.2016, 14:39. Просмотров 757. Ответов 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()
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
21.05.2016, 14:39
Здравствуйте! Я подобрал для вас темы с ответами на вопрос Коннектор к API используя AsyncIO, aiohttp (Python):

Supervisor,Mozilla Circus, cron. Aiohttp сервис - Python
Есть небольшой сервис написанный на aiohttp. Работает на сервере постоянно. Суть скрипта - на вход получает данные, обрабатывает их, сует в...

Выйти из петли в run_forever() [asyncio] - Python
Пишу скрипт, который эмулирует запуск игр в стиме. Для этого была выбрана библиотека Steam для питона (использую версию 3.4) Для...

С чего начать разбираться с Asyncio? - Python
нужно написать парсер страницы, с загрузкой некоторых картинок, на Asyncio. С многопоточным и асинхронным программированием дел не имел. ...

Asyncio корректное завершение в случае непредвиденной остановки программы - Python
Есть скрипт (выложен не полностью) @asyncio.coroutine def do_work(data): for adres, ip_list in data.items(): if len(ip_list) >3:...

Кто-нибудь уже использует aiohttp/muffin etc. ? - Python
Наконец-то разобрался с этим дремучим asyncio, не хотел он мне даваться никак, пришлось лопатить исходный код, чтобы понять как все эти...

Как можно запустить прогу, не используя функцию Shell, а используя API функцию? - Visual Basic
Привет Всем! Подскажите, как можно запустить прогу, не используя функцию Shell, а используя API функцию. Наверное PostMessage или...

0
MoreAnswers
Эксперт
37091 / 29110 / 5898
Регистрация: 17.06.2006
Сообщений: 43,301
21.05.2016, 14:39
Привет! Вот еще темы с ответами:

Авторизация в VK.com не используя API - Delphi
В общем пытался найти темы где описана авторизация в вк. без использования vk api. Статей много - но все старые. В общем, кинул на...

авторизация vk не используя vk api - Python
Здравствуйте. Нужно открыть сессию вконтакте, т.к пройти авторизацию,не используя api и selenium. Возможно ли это сделать с...

Редактировать текст используя ms Word API с++ - C++
Собственно, все описано в теме. Не могли бы вы помочь ссылками/объяснениями как это сделать?

Архивация файлов, используя библиотеку Win32 API - C (Си)
может кто поможет :) Используя библиотеку Win32 API. Тема:Разработка программы архивации файлов и каталогов алгоритмом арифметическое...


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

Или воспользуйтесь поиском по форуму:
1
Ответ Создать тему
Опции темы

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