Azure Storage Tableへの非同期書き込みがうまくいったので、いよいよ本命のSQL Databaseへの非同期書き込みにチャレンジ！

2020/02/24 追記
KeyVaultシークレット情報(接続文字列)を管理させるようにできました。後半に記載。

いつも通り情報があまりないです…C#の知識があればさくっと書けるのかもしれないですが、私にはないので手探りで進めます。

VisualStudioを利用してDB参照する方法は以下のサイトが非常に参考になります！
参考サイト：Azure FunctionsとSQLデータベースを連携する

１．Azure Storage Tableへの非同期書き込みと同様にテンプレから作成できるかと思いきや、ない。

ブレードから統合を選択し、出力から新規追加(+新しい出力)しても見当たらない。

２．コーディングの前の下準備（DB作成、テーブル作成）

参考サイトを元にDB作成

クエリエディタを利用


create table zodiac_type(
    id INT IDENTITY(1,1),
    name nvarchar(20)
)

insert into zodiac_type(name) values ('a');
insert into zodiac_type(name) values ('b');
insert into zodiac_type(name) values ('c');
insert into zodiac_type(name) values ('d');
insert into zodiac_type(name) values ('e');
insert into zodiac_type(name) values ('f');
insert into zodiac_type(name) values ('g');
insert into zodiac_type(name) values ('h');
insert into zodiac_type(name) values ('i');
insert into zodiac_type(name) values ('j');
insert into zodiac_type(name) values ('k');
insert into zodiac_type(name) values ('l');

３．DBへの書き込み処理は手で書く

１．アプリケーション設定にSQL Databaseの接続文字列を追加

２．コード内で先ほど設定した接続文字列が参照できることを確認

run.csx(一部)

var str = Environment.GetEnvironmentVariable("SQLDATABASE_CONNECT");
log.LogInformation($"{str}");

３．「Service Busトリガーで起動し、メッセージ内容をDBにINSERTする」処理を加える

Tips. Functionsの.Net Core3.1だとSystem.Data.SqlClientの一部の機能がコンパイルエラーになりました。~2.xに変更することで解消。（それでいいのか・・・）

run.csx(全量)

using System;
using System.Data.SqlClient;
using System.Threading.Tasks;

public static void Run(string myQueueItem, ILogger log)
{
    log.LogInformation($"C# ServiceBus queue trigger function processed message: {myQueueItem}");

   // Get the connection string from app settings and use it to create a connection.
    var str = Environment.GetEnvironmentVariable("SQLDATABASE_CONNECT");
    using (SqlConnection conn = new SqlConnection(str))
    {        
        try{
            // 接続文字列を利用してSQLDatabaseに接続
            conn.Open();
        }catch (Exception exc)
        { 
            log.LogInformation($"connect Error!");    
        }        
        var text = "select count(*) from [dbo].[zodiac_type];";
        using (SqlCommand cmd = new SqlCommand(text, conn))
        {
            // SQLの実行はココ selectなのでExecuteScalarクラスを利用
            var rows = cmd.ExecuteScalar();
            log.LogInformation($"{rows} rows were updated");
        }

        var queryCommand = "insert into [dbo].[zodiac_type] (name) values ('" + ($"{myQueueItem}") +"')";
        log.LogInformation($"{queryCommand}");   
        using (SqlCommand cmdcmd = new SqlCommand(queryCommand, conn))
        {
            // SQLの実行はココ insertなのでExecuteNonQueryクラスを利用
            var rowsrows = cmdcmd.ExecuteNonQuery();
        }
    }
}

４．Service Busに書き込まれた情報が無事SQL Databaseのnameテーブルに追加されたことを確認

ブラウザから打鍵

Azureポータル(コンソールログ)

2020-02-24T12:27:32.182 [Information] Executing 'Functions.ServiceBusQueueTrigger1' (Reason='New ServiceBus message detected on 'queue01'.', Id=********-e58a-477e-a9e9-1fc248e8f359)
2020-02-24T12:27:32.183 [Information] Trigger Details: MessageId: 589b9068e2a7440886d03930a2ecd770, DeliveryCount: 1, EnqueuedTime: 2/24/2020 12:27:32 PM, LockedUntil: 2/24/2020 12:28:02 PM, SessionId: (null)
2020-02-24T12:27:32.191 [Information] C# ServiceBus queue trigger function processed message: W
2020-02-24T12:27:32.193 [Information] 28 rows were updated
2020-02-24T12:27:32.194 [Information] insert into [dbo].[zodiac_type] (name) values ('W')
2020-02-24T12:27:32.201 [Information] Executed 'Functions.ServiceBusQueueTrigger1' (Succeeded, Id=********-e58a-477e-a9e9-1fc248e8f359)