在F#脚本中操作Azure Event Hub，如何避免调用Task.Result？

我正在用F#脚本向Azure Event Hub发布事件，对应的C#参考代码如下：

var connectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>";
var eventHubName = "<< NAME OF THE EVENT HUB >>";

await using (var producer = new EventHubProducerClient(connectionString, eventHubName))
{
    using EventDataBatch eventBatch = await producer.CreateBatchAsync();
    eventBatch.TryAdd(new EventData(new BinaryData("First")));
    eventBatch.TryAdd(new EventData(new BinaryData("Second")));

    await producer.SendAsync(eventBatch);
}

我自己写了一段能运行但不符合F#惯用写法的代码：

let producerClient = EventHubProducerClient(connectionString, eventHubName)
let cancellationToken = CancellationToken()
let eventDataBatch = 
  cancellationToken
  |> producerClient.CreateBatchAsync
let edb = eventDataBatch.Result
edb.TryAdd event
producerClient.SendAsync edb

注：我没有包含创建event的代码，它是一个JSON字符串。

请问如何避免调用Result，写出更简洁地道的F#代码？

要写出符合F#惯用风格的代码，核心是利用异步工作流处理异步操作，同时正确管理资源释放，彻底避免.Result的阻塞调用。以下是优化后的实现：

open System
open System.Text
open Azure.Messaging.EventHubs
open Azure.Messaging.EventHubs.Producer

// 封装为异步函数，符合F#函数式风格
let publishEventToHub connectionString eventHubName eventJson = async {
    // 使用use!自动释放异步创建的生产者客户端（对应C#的await using）
    use! producer = EventHubProducerClient(connectionString, eventHubName) |> Async.AwaitTask
    // 使用use!自动释放事件批次（对应C#的using）
    use! eventBatch = producer.CreateBatchAsync(CancellationToken()) |> Async.AwaitTask

    // 将JSON字符串转换为EventData
    let eventData = EventData(BinaryData(Encoding.UTF8.GetBytes(eventJson)))
    // 尝试添加事件到批次（可根据需要处理TryAdd的返回值判断是否添加成功）
    let _ = eventBatch.TryAdd(eventData)

    // 异步发送批次，用do!处理无返回值的异步操作
    do! producer.SendAsync(eventBatch) |> Async.AwaitTask |> Async.Ignore
}

// 调用示例
let connectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>"
let eventHubName = "<< NAME OF THE EVENT HUB >>"
let targetEventJson = "{\"id\":1,\"content\":\"sample event\"}"

// 在F#脚本中执行异步工作流
publishEventToHub connectionString eventHubName targetEventJson
|> Async.RunSynchronously

核心优化点 #

• 替代.Result：用Async.AwaitTask将.NET Task转换为F# async工作流，通过use!/let!异步等待结果，避免阻塞线程和潜在死锁。
• 自动资源管理：use!关键字会在异步工作流结束时自动释放EventHubProducerClient和EventDataBatch，等价于C#的await using和using，无需手动清理资源。
• 函数式封装：将发布逻辑封装为独立的async函数，便于复用、测试和与其他异步操作组合。
• 清晰的事件转换：显式处理JSON到EventData的转换，逻辑更直观。

内容的提问来源于stack exchange，提问作者Boggin