Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from https://www.nuget.org/packages/AWS.Lambda.Powertools.EventHandler below:

NuGet Gallery | AWS.Lambda.Powertools.EventHandler 1.0.1



• Easily handle publish and subscribe events with dedicated handler methods
• Automatic routing based on namespace and channel patterns
• Support for wildcard patterns to create catch-all handlers
• Process events in parallel or sequentially
• Control over event aggregation for batch processing
• Graceful error handling for individual events

AWS AppSync Events{target="_blank"}. A service that enables you to quickly build secure, scalable real-time WebSocket APIs without managing infrastructure or writing API code. It handles connection management, message broadcasting, authentication, and monitoring, reducing time to market and operational costs.

1. Install the NuGet package:

dotnet add package AWS.Lambda.Powertools.EventHandler --version 1.0.0

1. Add the AWS.Lambda.Powertools.EventHandler namespace to your Lambda function:

using AWS.Lambda.Powertools.EventHandler;

1. Update the AWS Lambda handler to use AppSyncEventsResolver

async Task<AppSyncEventsResponse> Handler(AppSyncEventsRequest appSyncEvent, ILambdaContext context)
{
    return await app.ResolveAsync(appSyncEvent, context);
}

using AWS.Lambda.Powertools.EventHandler;
using Amazon.Lambda.Core;
using Amazon.Lambda.RuntimeSupport;
using Amazon.Lambda.Serialization.SystemTextJson;
using AWS.Lambda.Powertools.EventHandler.AppSyncEvents;
using AWS.Lambda.Powertools.Logging;

var app = new AppSyncEventsResolver();

app.OnPublishAsync("/default/channel", async (payload) =>
{
    Logger.LogInformation("Published to /default/channel with {@payload}", payload);

    if (payload["eventType"].ToString() == "data_2")
    {
        throw new Exception("Error in /default/channel");
    }

    return "Hello from /default/channel";
});

app.OnPublishAggregateAsync("/default/channel2", async (payload) =>
{
    var evt = new List<AppSyncEvent>();
    foreach (var item in payload.Events)
    {
        var pd = new AppSyncEvent
        {
            Id = item.Id,
            Payload = new Dictionary<string, object>
            {
                { "demo", "demo" }
            }
        };

        if (item.Payload["eventType"].ToString() == "data_2")
        {
            pd.Payload["message"] = "Hello from /default/channel2 with data_2";
            pd.Payload["data"] = new Dictionary<string, object>
            {
                { "key", "value" }
            };
        }

        evt.Add(pd);
    }

    Logger.LogInformation("Published to /default/channel2 with {@evt}", evt);
    return new AppSyncEventsResponse
    {
        Events = evt
    };
});

app.OnSubscribeAsync("/default/*", async (payload) =>
{
    Logger.LogInformation("Subscribed to /default/* with {@payload}", payload);
    return true;
});

async Task<AppSyncEventsResponse> Handler(AppSyncEventsRequest appSyncEvent, ILambdaContext context)
{
    return await app.ResolveAsync(appSyncEvent, context);
}

await LambdaBootstrapBuilder.Create((Func<AppSyncEventsRequest, ILambdaContext, Task<AppSyncEventsResponse>>)Handler,
new DefaultLambdaJsonSerializer())
        .Build()
        .RunAsync();

This package is not used by any NuGet packages.

This package is not used by any popular GitHub repositories.

AWS Amazon Lambda Powertools

Copyright 2023 Amazon.com, Inc. or its affiliates. All Rights Reserved.

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4