问题内容
我对我的函数应用“timertrigger”有疑问。
我开发了此功能来与 telegram 机器人进行通信，以便在 api 请求后发送消息。
我在本地尝试过该功能应用程序，效果很好。但是，当我尝试使用 cosmosdb 存储信息时，遇到问题并且无法保存信息。
我已经设置了将我的应用程序与 telegram 和 cosmosdb 连接所需的所有变量和内容
try:
database_obj = client.get_database_client(database_name)
await database_obj.read()
return database_obj
except exceptions.cosmosresourcenotfounderror:
print("creating database")
return await client.create_database(database_name)
#
# create a container
# using a good partition key improves the performance of database operations.
#
async def get_or_create_container(database_obj, container_name):
try:
todo_items_container = database_obj.get_container_client(container_name)
await todo_items_container.read()
return todo_items_container
except exceptions.cosmosresourcenotfounderror:
print("creating container with lastname as partition key")
return await database_obj.create_container(
id=container_name,
partition_key=partitionkey(path="/lastname"),
offer_throughput=400)
except exceptions.cosmoshttpresponseerror:
raise
#
async def populate_container_items(container_obj, items_to_create):
# add items to the container
family_items_to_create = items_to_create
#
for family_item in family_items_to_create:
inserted_item = await container_obj.create_item(body=family_item)
print("inserted item for %s family. item id: %s" %(inserted_item['lastname'], inserted_item['id']))
#
#
async def read_items(container_obj, items_to_read):
# read items (key value lookups by partition key and id, aka point reads)
#
for family in items_to_read:
item_response = await container_obj.read_item(item=family['id'], partition_key=family['lastname'])
request_charge = container_obj.client_connection.last_response_headers['x-ms-request-charge']
print('read item with id {0}. operation consumed {1} request units'.format(item_response['id'], (request_charge)))
#
#
#
async def query_items(container_obj, query_text):
# enable_cross_partition_query should be set to true as the container is partitioned
# in this case, we do have to await the asynchronous iterator object since logic
# within the query_items() method makes network calls to verify the partition key
# definition in the container
#
query_items_response = container_obj.query_items(
query=query_text,
enable_cross_partition_query=true
)
request_charge = container_obj.client_connection.last_response_headers['x-ms-request-charge']
items = [item async for item in query_items_response]
print('query returned {0} items. operation consumed {1} request units'.format(len(items), request_charge))
#
#
async def run_sample():
print('aaaa')
print('sss {0}'.format(cosmosclient(endpoint,credential=key)))
async with cosmosclient(endpoint, credential = key) as client:
print('connected to db')
try:
database_obj = await get_or_create_db(client, database_name)
# create a container
container_obj = await get_or_create_container(database_obj, container_name)
family_items_to_create = ["link", "ss", "s", "s"]
await populate_container_items(container_obj, family_items_to_create)
await read_items(container_obj, family_items_to_create)
# query these items using the sql query syntax.
# specifying the partition key value in the query allows cosmos db to retrieve data only from the relevant partitions, which improves performance
query = "select * from c "
await query_items(container_obj, query)
except exceptions.cosmoshttpresponseerror as e:
print('\nrun_sample has caught an error. {0}'.format(e.message))
finally:
print("\nquickstart complete")
async def main(mytimer: func.timerrequest) -> none:
utc_timestamp = datetime.datetime.utcnow().replace(
tzinfo=datetime.timezone.utc).isoformat()
asyncio.create_task(run_sample())
logging.info(' sono partito')
sendnews()
if mytimer.past_due:
logging.info('the timer is past due!')
logging.info('python timer trigger function ran at %s', utc_timestamp)
我已经开始我的功能
func host start --port 7072
但我认为与数据库的连接出了问题，因为 console.log('connected to db') 没有被打印。
似乎所有与cosmosdb相关的操作都没有执行，如果有错误不知道如何解决。
我的终端中没有任何错误，但正如我所说，cosmosdb 似乎不起作用。
SUN2008 企业网站管理系统2.0 beta
下载
1、数据调用该功能使界面与程序分离实施变得更加容易，美工无需任何编程基础即可完成数据调用操作。2、交互设计该功能可以方便的为栏目提供个性化性息功能及交互功能，为产品栏目添加产品颜色尺寸等属性或简单的留言和订单功能无需另外开发模块。3、静态生成触发式静态生成。4、友好URL设置网页路径变得更加友好5、多语言设计1)UTF8国际编码; 2)理论上可以承担一个任意多语言的网站版本。6、缓存机制减轻服务器
我不确定是否向您提供了所有必要的信息。感谢您的帮助。
正确答案
我在使用异步函数时也遇到了同样的问题。当我使用非异步函数时，它对我有用。
参考请查看此 document
我的代码：
timetrigger1/__init__.py：
import datetime
import logging
import asyncio
import azure.functions as func
from azure.cosmos import cosmos_client
import azure.cosmos.exceptions as exceptions
from azure.cosmos.partition_key import partitionkey
endpoint = "https://timercosmosdb.documents.azure.com/"
key = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
database_name = "todolist"
container_name = "test"
def get_or_create_db(client,database_name):
try:
database_obj = client.get_database_client(database_name)
database_obj.read()
return database_obj
except exceptions.cosmosresourcenotfounderror:
logging.info("creating database")
return client.create_database_if_not_exists(database_name)
def get_or_create_container(database_obj, container_name):
try:
todo_items_container = database_obj.get_container_client(container_name)
todo_items_container.read()
return todo_items_container
except exceptions.cosmosresourcenotfounderror:
logging.info("creating container with lastname as partition key")
return database_obj.create_container_if_not_exists(
id=container_name,
partition_key=partitionkey(path="/id"),
offer_throughput=400)
except exceptions.cosmoshttpresponseerror:
raise
def populate_container_items(container_obj,items):
inserted_item = container_obj.create_item(body=items)
logging.info("inserted item for %s family. item id: %s" %(inserted_item['lastname'], inserted_item['id']))
def read_items(container_obj,id):
item_response = container_obj.read_item(item=id, partition_key=id)
request_charge = container_obj.client_connection.last_response_headers['x-ms-request-charge']
logging.info('read item with id {0}. operation consumed {1} request units'.format(item_response['id'], (request_charge)))
def query_items(container_obj, query_text):
query_items_response = container_obj.query_items(
query=query_text,
enable_cross_partition_query=true
)
request_charge = container_obj.client_connection.last_response_headers['x-ms-request-charge']
items = [item for item in query_items_response]
logging.info('query returned {0} items. operation consumed {1} request units'.format(len(items), request_charge))
def run_sample():
logging.info('aaaa')
client = cosmos_client.cosmosclient(endpoint, key)
logging.info('connected to db')
try:
id= "test"
database_obj = get_or_create_db(client,database_name)
container_obj = get_or_create_container(database_obj,container_name)
item_dict = {
"id": id,
"lastname": "shandilya",
"firstname": "vivek",
"gender": "male",
"age": 35
}
populate_container_items(container_obj,item_dict)
read_items(container_obj,id)
query = "select * from c "
query_items(container_obj, query)
except exceptions.cosmoshttpresponseerror as e:
logging.info('\nrun_sample has caught an error. {0}'.format(e.message))
finally:
logging.info("\nquickstart complete")
def main(mytimer: func.timerrequest) -> none:
utc_timestamp = datetime.datetime.utcnow().replace(
tzinfo=datetime.timezone.utc).isoformat()
run_sample()
logging.info(' sono partito')
logging.info('python timer trigger function ran at %s', utc_timestamp)
output：
functions:
timertrigger1: timertrigger
for detailed output, run func with --verbose flag.
[2024-01-30t09:00:24.818z] executing 'functions.timertrigger1' (reason='timer fired at 2024-01-30t14:30:24.7842979+05:30', id=5499e180-4964-4d7e-b9f2-b024860945dd)
[2024-01-30t09:00:24.822z] trigger details: unscheduledinvocationreason: ispastdue, originalschedule: 2024-01-30t14:30:00.0000000+05:30
[2024-01-30t09:00:25.022z] aaaa
[2024-01-30t09:00:26.387z] connected to db
[2024-01-30t09:00:28.212z] inserted item for shandilya family. item id: test
[2024-01-30t09:00:28.373z] read item with id test. operation consumed 1 request units
[2024-01-30t09:00:28.546z]
quickstart complete
[2024-01-30t09:00:28.548z] python timer trigger function ran at 2024-01-30t09:00:25.008468+00:00
[2024-01-30t09:00:28.547z] sono partito
[2024-01-30t09:00:28.546z] query returned 1 items. operation consumed 1 request units
[2024-01-30t09:00:28.592z] executed 'functions.timertrigger1' (succeeded, id=5499e180-4964-4d7e-b9f2-b024860945dd, duration=3793ms)
[2024-01-30t09:00:29.296z] host lock lease acquired by instance id '000000000000000000000000aae5f384'.
{
"id": "test",
"lastName": "Shandilya",
"firstName": "Vivek",
"gender": "male",
"age": 35,
"_rid": "ey58AO9yWqwCAAAAAAAAAA==",
"_self": "dbs/ey58AA==/colls/ey58AO9yWqw=/docs/ey58AO9yWqwCAAAAAAAAAA==/",
"_etag": "\"01001327-0000-1a00-0000-65b8baac0000\"",
"_attachments": "attachments/",
"_ts": 1706605228
}
