如何在Jupyter notebooks中终止异步任务(使用Python从Eventhub接收数据)

from azure.eventhub.aio import EventHubConsumerClient
from azure.eventhub.extensions.checkpointstoreblobaio import BlobCheckpointStore
import asyncio

async def on_event(partition_context, event):
    # 处理接收到的数据
    print(event.body_as_str())
    await partition_context.update_checkpoint(event)

async def receive_data():
    # 定义Eventhub连接字符串和相关参数
    connection_str = "<Eventhub连接字符串>"
    consumer_group = "<消费者组名称>"
    eventhub_name = "<Eventhub名称>"
    checkpoint_store = BlobCheckpointStore.from_connection_string("<存储连接字符串>", "<存储容器名称>")

    # 创建Eventhub消费者客户端
    client = EventHubConsumerClient.from_connection_string(
        connection_str, consumer_group, eventhub_name=eventhub_name, checkpoint_store=checkpoint_store
    )

    # 启动消费者客户端并接收数据
    async with client:
        await client.receive(on_event=on_event, starting_position="-1")

# 创建并启动异步任务
task = asyncio.ensure_future(receive_data())

task.cancel()