public static void Run(string input, TraceWriter log)
{
log.Info("SimpleProducer");
KafkaOptions options = new KafkaOptions(new Uri("http://*******:9092"));
BrokerRouter router = new BrokerRouter(options);
Producer client = new Producer(router);
while(true)
{
JObject obj = JObject.FromObject(new
{
ExchangeName = "BitFinex",
CurrencyPair = "Dollar",
MachineTime = DateTime.Now.ToString("dd-MM-yyyy_HH:mm:ss.ffffff"),
OrderSide = "Buy",
OrderId = "123",
Price = "10",
Quantity = "100"
});
log.Info(obj.ToString(Formatting.None));
client.SendMessageAsync("tenant", new[] { new Message(obj.ToString(Formatting.None)) }).Wait();
log.Info("Next Iteration");
}
}
私はループを使って、紺碧の蒼穹の機能で連続的にデータを処理しました。しかし、紺色の機能は5〜6分後に停止し、もう一度蒼白の機能を再実行する必要があります。 azure関数を連続して実行するための設定はありますか?上記のコードを使用しました。5〜6分後に蒼白の機能を停止させると、それを継続的に実行する方法を教えてください。
Azure関数は主にイベント駆動型です。これは、関数(タイマー、キュー、ストレージなど)をトリガするために何か必要なことを意味します。したがって、これはあなたが達成しようとしているものに対して不適切な機能になります。 – Chris