Azureのタイマートリガーの使用キュー処理の機能

Question

データベースに挿入する必要があるレコードを持つキューを処理するAzure関数があります。その働くファイン。しかし、私は30秒ごとにレコードを確認できるように、queueTriggerの代わりにTimerトリガーを使いたいと思っていました。誰か助けてもらえますか？ https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-timerに記載されているタイマーの基本的な実装を試しましたが、どのようにレコードを処理できるのか分かりません。

Answer 1

最後のコメントに基づいて、キュートリガーを使用する必要がない場合（メッセージが多すぎる場合は問題ありません。Azureは、すべてのメッセージを処理するために必要なリソースを拡大/縮小しますあなたは、しかし、それはしばらくのために実行するために高価になることができます）あなたは単にConsole Appで使用する同じコードをAzure関数にアップロードすることができます。ここで

は、C＃でキューからデータを消費する方法の例です：https://docs.microsoft.com/en-us/azure/storage/storage-dotnet-how-to-use-queues

あなただけ.csxスクリプト（あなたがのMainメソッドに入れたコードとして実行するコードを適応させる必要がありますコンソールアプリケーションは、.csxスクリプトのRunメソッドに入れたコードと同じコードになります）。

Answer 2

キュー入力バインディングを使用してCloudQueueにバインドできます。

ここに、キューからメッセージをフェッチするTimerTriggerのサンプルコードを示します。

Function.json

{ 
    "bindings": [ 
    { 
     "type": "timerTrigger", 
     "name": "myTimer", 
     "schedule": "0 * * * * *", 
     "direction": "in" 
    }, 
    { 
     "type": "queue", 
     "name": "clQueue", 
     "queueName": "myqueue", 
     "connection": "", 
     "direction": "in" 
    } 
    ], 
    "disabled": false 
} 

Run.csx

#r "Microsoft.WindowsAzure.Storage" 

using Microsoft.WindowsAzure.Storage.Queue; 

public static async Task Run(TimerInfo myTimer, CloudQueue clQueue, TraceWriter log) 
{ 
    var message = await clQueue.GetMessageAsync(); 
    log.Info($"{message.As​String}");   

    clQueue.DeleteMessage(message); 
} 

Answer 3

これは私のために働いていた答えである： 使用した場合のAzureキューまたはServiceBusキューへの直接結合はありませんタイマートリガー。関数またはコンソールアプリケーションを使用していない場合は、キュー接続と書き込みロジックを自分で記述する必要があります。 ServiceBus Queueから単一のメッセージを読み取るための例として、次のようなものがあります。

var connectionString = "Endpoint = sb：//.servicebus.windows.net/; SharedAccessKeyName = RootManageSharedAccessKey; SharedAccessKey =" "; var queueName = "";

var client = QueueClient.CreateFromConnectionString（connectionString、queueName）; var message = client.Receive（）;