如何保障API Management中log-to-eventhub策略的传输可靠性？

我来帮你梳理下APIM里log-to-eventhub策略的可靠性保障方案，刚好我之前也处理过类似需求——官方文档确实没把这块细节写透，但咱们可以通过组合APIM的内置策略来实现你要的重试和失败抛错逻辑。

一、先搞懂默认的重试行为 #

首先，log-to-eventhub策略其实自带基础的重试机制，针对网络波动、Event Hub临时不可用这类瞬时错误，它会自动重试几次。但如果是持久化错误（比如logger-id配置错了、APIM没有Event Hub的发送权限），重试是没用的，而且默认情况下，日志发送失败不会阻断主请求的流程——这也是你要解决的核心问题。

二、实现“失败即抛错”的逻辑 #

如果你要求只要日志发不出去，主请求就必须返回错误，那可以用try-catch策略来包裹log-to-eventhub，捕获发送失败的异常并主动返回错误：

<policies>
    <inbound>
        <set-variable name="test1" value="1" />
        <try>
            <log-to-eventhub logger-id="CslLog" partition-id="0">
                @{ 
                    return new JObject( new JProperty("test1", context.Variables["test1"]) ).ToString(); 
                }
            </log-to-eventhub>
        </try>
        <catch>
            <!-- 日志发送失败时，直接返回500错误给客户端 -->
            <return-response>
                <set-status code="500" reason="Log Delivery Failed" />
                <set-body>{"error": "Failed to send request log to Event Hub: @(context.LastError.Message)"}</set-body>
            </return-response>
        </catch>
        <base />
    </inbound>
</policies>

三、自定义重试逻辑（针对临时错误） #

如果想针对瞬时错误增加重试次数和间隔，用retry策略包裹log-to-eventhub就可以，还能指定只对特定类型的错误重试：

<policies>
    <inbound>
        <set-variable name="test1" value="1" />
        <!-- 针对连接失败、超时这类临时错误，重试3次，每次间隔1秒 -->
        <retry condition="@(context.LastError != null && 
                          (context.LastError.Reason == "ConnectionFailure" || context.LastError.Reason == "Timeout"))" 
               count="3" interval="1" first-fast-retry="true">
            <log-to-eventhub logger-id="CslLog" partition-id="0">
                @{ 
                    return new JObject( new JProperty("test1", context.Variables["test1"]) ).ToString(); 
                }
            </log-to-eventhub>
        </retry>
        <!-- 重试后仍失败，抛出错误 -->
        <choose>
            <when condition="@(context.LastError != null)">
                <return-response>
                    <set-status code="500" reason="Log Delivery Failed After Retries" />
                    <set-body>{"error": "Failed to send log to Event Hub after 3 retries: @(context.LastError.Message)"}</set-body>
                </return-response>
            </when>
        </choose>
        <base />
    </inbound>
</policies>

这里的condition可以根据实际错误类型调整，比如你可以查看context.LastError的具体字段，区分临时错误和永久错误，避免无效重试。

四、额外的可靠性小技巧 #

• 用批量日志策略：如果你的请求量很大，换成log-to-eventhub-batch策略，它会批量攒日志再发送，减少连接次数，可靠性更高。
• 监控失败指标：在APIM的监控面板里，关注EventHubLoggerFailedRequests这个指标，能及时发现日志发送失败的趋势。
• 启用Event Hub捕获：给你的Event Hub开启捕获功能，把未成功处理的消息持久化到存储账户，万一有漏发的日志，后续可以离线补传。

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