如何知道异步 Azure 函数的 SendGrid 消息何时失败？

Question

我设置了一个 azure 函数，用于从事件中心读取，以通过 sendgrid 或 twilio 发送警报消息。我希望能够判断何时发送SendGrid消息“await smsCollector.AddAsync（mobileMessage）”是否成功发送 - 即电子邮件不是无效的。这种设置可以吗？

         public static class SendAlert
         {
        [FunctionName("v1_EventHub_SendAlert")]
        public static async Task Run(
            [EventHubTrigger("v1-email-hub", Connection = "EventHubConnection")] EventData[] events,
            [SendGrid] IAsyncCollector<SendGridMessage> messageCollector,
            [TwilioSms(From = "xXXXxxXxxx)] IAsyncCollector<CreateMessageOptions> smsCollector,
            [Inject] NotificationEventLogic eventLogic,
            [Inject] NotificationLogic notificationLogic,
            ILogger log)
        {
            foreach (EventData eventData in events)
            {
                string messageBody = Encoding.UTF8.GetString(eventData.Body.Array, eventData.Body.Offset, eventData.Body.Count);

                var notificationEvents = JsonConvert.DeserializeObject<List<NotificationEvent>>(messageBody);

                foreach (var ev in notificationEvents)
                {
                    var notification = await notificationLogic.GetNotificationAsync(ev.NotificationId);

                    if (ev.NotificationEventType == NotificationEventType.Email)
                    {
                        var message = CreateEmail(ev, notification);
                        await messageCollector.AddAsync(message);
                    }
                    else if (ev.NotificationEventType == NotificationEventType.SMS)
                    {
                        var mobileMessage = CreateSms(ev, notification);

                        await smsCollector.AddAsync(mobileMessage);
                    }

                    await eventLogic.CreateEventAsync(ev);
                }

            }
        }

Answer 1

IAsyncCollector 有一个可以调用的 FlushAsync 方法。AddAsync 可以缓冲项目，但 FlushAsync 会强制它们通过（并在出错时引发异常）。