如何解决asyncio 不适用于 Google Cloud Functions
我有这个函数,它在我的机器上使用 python 3.8 在本地运行良好,但它在 Google Cloud Functions 上抛出运行时错误。
def telegram_test(request):
request_json = request.get_json()
import datetime
import pandas as pd
from pyrogram import Client
session_string = "...............38Q8uTHG5gHwyWD8nW6h................."
# the rest of the authantication
api_id = 32494131641215
api_hash = "ioadsfsjnjksfgnfriuthg#qw]/zwq ]w/\lc ec,"
# one of bbc channels on telegram you want to access
channel_name = 'pyrogram'
# if you only want to get messages older than 7 days in unix style
seven_days = int((datetime.datetime.Now() - datetime.timedelta(days=7)).timestamp())
# call telegram with parameters such as limit and date
# save the result to dataframe
with Client(session_string,api_id,api_hash,takeout=True,workers=2) as app:
hist_iter = app.iter_history(channel_name,offset_date=seven_days,limit=100)
msglist = [msg.__dict__ for msg in hist_iter]
df = pd.DataFrame(msglist)
print(df.head(5))
return f'it works!:{request_json}'
我从 GCF 日志中得到的错误消息:
文件“/opt/python3.8/lib/python3.8/asyncio/events.py”,第 639 行,在 get_event_loop raise RuntimeError('没有当前事件循环 线程 %r.'运行时错误:线程中没有当前事件循环 'ThreadPoolExecutor-0_0'。
更新
我更新了代码,运行时错误消失了。但我收到超时错误。 我把超时设置为 180 秒,但是当我测试该函数时仍然超时 60 秒。
这是更新后的代码。我做错了什么吗?
async def foo():
from datetime import datetime,timedelta
from pandas import DataFrame
from pyrogram import Client
import asyncio
session_string = "********zNmkubA4ibjsdjhsdfjlhweruifnjkldfioY5DE*********"
api_id = 325511548224831351
api_hash = "jdffjgtrkjhfklmrtgjtrm;sesews;;wex"
channel_name = 'cnn'
with Client(session_string,takeout=True) as app:
hist_iter = app.iter_history(
channel_name,limit=10)
msglist = [msg.__dict__ for msg in hist_iter]
df = DataFrame(msglist)
return df
async def bar():
return await foo()
def test(request):
from asyncio import run
return run(bar())
解决方法
最终的解决方案是从 Pyrogram 更改为 Telethon,并在创建客户端之前手动创建 asyncio。
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
,
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。