Azure 関数から Azure ロジック アプリへのサーフェス エラーによるエラー追跡を改善する方法

Azure Functions にエラー処理を実装して Logic Apps の問題を表面化する

呼び出し元の Azure ロジック アプリによってキャッチされるエラーをスローする C# バックエンド ソリューションを備えた Azure 関数

// This code demonstrates a C# Azure Function designed to throw an error
// that can be caught by an Azure Logic App.
// The script uses structured error handling to ensure clear reporting in the Logic App.

using System;
using System.IO;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using System.Data.SqlClient;

public static class MyFunction
{
    [FunctionName("MyFunction")]
    public static async Task<IActionResult> Run(
        [HttpTrigger(AuthorizationLevel.Function, "post", Route = null)] HttpRequest req,
        ILogger log)
    {
        log.LogInformation("MyFunction triggered.");
        try
        {
            // Simulating database operation
            using (SqlConnection connection = new SqlConnection("YourConnectionStringHere"))
            {
                connection.Open();
                var command = new SqlCommand("INSERT INTO Table (Column) VALUES (Value);", connection);
                command.ExecuteNonQuery();
            }
            return new OkObjectResult("Data inserted successfully");
        }
        catch (SqlException ex)
        {
            log.LogError($"Database error: {ex.Message}");
            return new StatusCodeResult(StatusCodes.Status500InternalServerError);
        }
        catch (Exception ex)
        {
            log.LogError($"General error: {ex.Message}");
            return new StatusCodeResult(StatusCodes.Status500InternalServerError);
        }
    }
}

HTTP ステータス コードを使用して Azure 関数のエラーを通知する (JavaScript ソリューション)

Azure Logic Apps でフラグが立てられるエラーを処理するための Node.js バックエンド関数

// This JavaScript function handles database operations and triggers an error response
// with an HTTP 500 status code if a failure occurs, allowing the Logic App to detect it.

const { Connection, Request } = require('tedious');

module.exports = async function (context, req) {
    context.log('JavaScript Azure Function triggered.');
    try {
        const config = {
            server: "YourServerHere",
            authentication: {
                type: "default",
                options: {
                    userName: "username",
                    password: "password"
                }
            }
        };

        const connection = new Connection(config);
        connection.on('connect', err => {
            if (err) {
                context.log.error('Database connection error', err);
                context.res = { status: 500, body: "Database connection error" };
                return;
            }

            const request = new Request("INSERT INTO Table (Column) VALUES ('Value')", err => {
                if (err) {
                    context.log.error('Database insert error', err);
                    context.res = { status: 500, body: "Database insert error" };
                } else {
                    context.res = { status: 200, body: "Data inserted successfully" };
                }
            });
            connection.execSql(request);
        });
        connection.connect();
    } catch (error) {
        context.log.error('General error', error);
        context.res = { status: 500, body: "General error occurred" };
    }
};

C# Azure 関数の単体テスト

MSTest を使用してエラー処理を検証する C# Azure 関数の単体テスト

using Microsoft.VisualStudio.TestTools.UnitTesting;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging;

[TestClass]
public class MyFunctionTests
{
    [TestMethod]
    public async Task Run_ShouldReturn500_OnSqlException()
    {
        var mockLogger = new Mock<ILogger>();
        var request = new DefaultHttpContext().Request;

        // Act - Call the function
        var response = await MyFunction.Run(request, mockLogger.Object);

        // Assert
        Assert.IsInstanceOfType(response, typeof(StatusCodeResult));
        Assert.AreEqual(500, (response as StatusCodeResult)?.StatusCode);
    }
}

Logic Apps での Azure 関数エラーの処理に関するよくある質問

1. ロジック アプリが Azure 関数からのエラーを確実にキャッチするにはどうすればよいですか?
2. ロジック アプリがエラーを確実に検出するには、次のような HTTP ステータス コードを返します。 500、Azure 関数でエラーが発生したとき。これにより、ロジック アプリは応答を失敗として解釈できるようになります。
3. エラー処理のためにロジック アプリに再試行ポリシーを追加できますか?
4. はい、Logic Apps は構成可能な再試行ポリシーを提供します。 Azure 関数の予想される動作に基づいて、再試行の試行と間隔を調整できます。
5. Azure Function で構造化ログを使用する利点は何ですか?
6. 構造化ロギングなど ILoggerを使用すると、詳細なエラー メッセージをキャプチャでき、ワークフロー内の特定の問題の監視とトラブルシューティングに使用できます。
7. エラーが発生した場合でも、Azure 関数で HTTP 200 応答を使用する必要がありますか?
8. いいえ、使用しています HTTP 200 エラーがあると、ロジック アプリが関数の状態を誤って解釈する可能性があります。代わりに、失敗した場合は、500 などの適切なエラー ステータス コードを返します。
9. Azure Function での接続の問題をトラブルシューティングするにはどうすればよいですか?
10. SQL 接続と権限を確認してください。使用する SqlConnection そのエラーをログに記録すると、アクセス許可の拒否やサーバーへのアクセス不能など、接続関連の問題を特定するのに役立ちます。
11. ロジック アプリがエラーを正しく検出しない場合はどうなりますか?
12. エラーが検出されない場合は、すべての応答をログに記録するか、ステータス コードを使用して問題をより正確に特定するようにロジック アプリを構成します。このアプローチにより、関数エラーに対するロジック アプリの応答が強化されます。
13. エラー信号にカスタム HTTP ステータス コードを使用できますか?
14. はい、その間に 500 はサーバー エラーの標準です。ワークフローに適している場合は他のステータス コードを使用できますが、誤解を避けるために一貫性を保つ必要があります。
15. JavaScript ベースの Azure Functions にはどのようなエラー処理オプションがありますか?
16. 使用 context.log.error() ログ記録と status 応答内のフィールドを使用して、JavaScript ベースの関数の Logic Apps でエラー処理をトリガーします。
17. 再試行ポリシーは Azure Functions のデータ整合性にどのような影響を与えますか?
18. 再試行ポリシーでは Azure 関数を複数回再試行できるため、次のような操作を必ず実行してください。 ExecuteNonQuery()、データベース内の重複エントリを避けるために冪等です。
19. 関数にエラーがある場合でも、ロジック アプリで正常な実行が表示されるのはなぜですか?
20. Azure 関数が返った場合 HTTP 200 エラーがあっても、ロジック アプリはそれを成功として解釈します。使用する StatusCodeResult 失敗コードを送信すると、この動作が修正されます。
21. 単体テストは Azure Functions のエラー処理の改善にどのように役立ちますか?
22. 単体テストでは、エラーをシミュレートし、関数が次のような正しいステータス コードを返すかどうかを確認することで、エラー処理を検証できます。 StatusCodeResult(500)、堅牢なロジック アプリ統合を保証します。

堅牢なエラー処理によりワークフローの信頼性を確保

Azure 関数とロジック アプリ間の効果的なエラー処理により、可視性が向上し、問題への迅速な対応が可能になります。エラーに対して正しい HTTP ステータス コードを返すと、エラーが発生したことがロジック アプリに通知され、ロジック アプリはそれに応じて応答できるようになります。構造化されたロギングおよび再試行ポリシーは、この信頼性をさらにサポートします。

Azure Functions に詳細なログ記録と構造化された応答を組み込むことで、よりスムーズで信頼性の高いワークフローが保証されます。この設定を再試行ポリシーと組み合わせると、サイレント障害が最小限に抑えられ、データの流れとシステムの動作が維持されます。これらの戦略を導入すると、チームは時間を節約し、自信を持ってシステムの健全性を維持できます。 🚀