Azure 函数 - 带有 CreateSubscriptionStream 的 GraphQLHttpClient

Question

我有一个要求，比如我想使用 CreateSubscriptionStream 将 GraphQLHttpClient 订阅到函数应用中。

stream.Subscribe(
                response =>
                {
                    Console.WriteLine($"RaceUpdatesSubscription message: \"{response.Data}\" ");
                    SendMsgToTopic.SendMessageToTopicAsync(response.Data, _serviceBusConnectionString, _raceUpdatesTopicName).Wait();
                },
                exception => Console.WriteLine($"message RaceUpdatesSubscription stream failed: {exception}"),
                () => Console.WriteLine($"message RaceUpdatesSubscription stream completed")
            );

我怎样才能做到这一点就像有什么方法可以从 azure 函数中使用任何触发器或注册它以进行订阅（发生任何更改然后我需要听）

现在它可以在控制台应用程序中正常工作，但尝试使用函数应用程序。

Answer 1

将 CreateSubscriptionStream 创建到函数应用中。以下是订阅详情

// To use NewtonsoftJsonSerializer, add a reference to NuGet package GraphQL.Client.Serializer.Newtonsoft
var graphQLClient = new GraphQLHttpClient("https://api.example.com/graphql", new NewtonsoftJsonSerializer());

下面是使用订阅的代码

public class UserJoinedSubscriptionResult {
    public ChatUser UserJoined { get; set; }

    public class ChatUser {
        public string DisplayName { get; set; }
        public string Id { get; set; }
    }
}

下面是创建订阅的代码

var userJoinedRequest = new GraphQLRequest {
    Query = @"
    subscription {
        userJoined{
            displayName
            id
        }
    }"
};

IObservable<GraphQLResponse<UserJoinedSubscriptionResult>> subscriptionStream 
    = client.CreateSubscriptionStream<UserJoinedSubscriptionResult>(userJoinedRequest);

var subscription = subscriptionStream.Subscribe(response => 
    {
        Console.WriteLine($"user '{response.Data.UserJoined.DisplayName}' joined")
    });

要获得有关 CreateSubscriptionStream 的完整信息，请参阅GraphQL