Enabling csharp webhook and proxy heartbeat functions (#2263)

* Enabling csharp webhook and proxy heartbeat trigger

* Adding deploy exemption.

* Fixing queue table.

* Adding function to bicep.

* Renaming function.
This commit is contained in:
Noah McGregor Harper
2022-08-17 16:29:47 -07:00
committed by GitHub
parent f5b647ef1b
commit f134c0f122
4 changed files with 6 additions and 5 deletions

View File

@ -14,8 +14,8 @@ public class QueueProxyHearbeat {
_proxy = proxy; _proxy = proxy;
} }
//[Function("QueueProxyHearbeat")] [Function("QueueProxyUpdate")]
public async Async.Task Run([QueueTrigger("myqueue-items", Connection = "AzureWebJobsStorage")] string msg) { public async Async.Task Run([QueueTrigger("proxy", Connection = "AzureWebJobsStorage")] string msg) {
_log.Info($"heartbeat: {msg}"); _log.Info($"heartbeat: {msg}");
var hb = JsonSerializer.Deserialize<ProxyHeartbeat>(msg, EntityConverter.GetJsonSerializerOptions()).EnsureNotNull($"wrong data {msg}"); ; var hb = JsonSerializer.Deserialize<ProxyHeartbeat>(msg, EntityConverter.GetJsonSerializerOptions()).EnsureNotNull($"wrong data {msg}"); ;

View File

@ -12,8 +12,8 @@ public class QueueWebhooks {
_webhookMessageLog = webhookMessageLog; _webhookMessageLog = webhookMessageLog;
} }
//[Function("QueueWebhooks")] [Function("QueueWebhooks")]
public async Async.Task Run([QueueTrigger("myqueue-items", Connection = "AzureWebJobsStorage")] string msg) { public async Async.Task Run([QueueTrigger("webhooks", Connection = "AzureWebJobsStorage")] string msg) {
_log.Info($"Webhook Message Queued: {msg}"); _log.Info($"Webhook Message Queued: {msg}");

View File

@ -354,7 +354,7 @@ module netFunctionSettings 'bicep-templates/function-settings.bicep' = {
'Proxy' //16 'Proxy' //16
'QueueFileChanges' //17 'QueueFileChanges' //17
'QueueNodeHeartbeat' //18 'QueueNodeHeartbeat' //18
'QueueProxyUpdate' //19 'QueueProxyUpdate' //19
'QueueSignalrEvents' //20 'QueueSignalrEvents' //20
'QueueTaskHeartbeat' //21 'QueueTaskHeartbeat' //21
'QueueUpdates' //22 'QueueUpdates' //22

View File

@ -1147,6 +1147,7 @@ class Client:
], ],
env=dict(os.environ, CLI_DEBUG="1"), env=dict(os.environ, CLI_DEBUG="1"),
) )
# enable dotnet function # enable dotnet function
logger.info(f"enabling DOTNET function: {dotnet_name}") logger.info(f"enabling DOTNET function: {dotnet_name}")
subprocess.check_output( subprocess.check_output(