如何解决graphql-ruby订阅无法正常播放
我有一个准系统设置,可以通过Action Cable用graphql-ruby更新广播。
- 客户端将收到初始的有效载荷,用于订阅。
- 客户端未收到任何更新,并且未调用订阅类型的
update
方法。后端没有错误。触发器调用似乎被静默忽略。这就是我要解决的问题/正确理解它应该如何工作。
我正在查看的文档:
- https://graphql-ruby.org/subscriptions/subscription_classes.html
- https://graphql-ruby.org/subscriptions/triggers
订阅类型:
module Types
class SubscriptionType < Types::BaseObject
field :server_info,subscription: Subscriptions::ServerInfoSubscription,null: false
end
end
module Subscriptions
class ServerInfoSubscription < Subscriptions::BaseSubscription
field :date_time,GraphQL::Types::ISO8601DateTime,null: false
def subscribe
{ date_time: DateTime.now }
end
def update
puts 'UPDATE CALLED' # Nope,it's not being called
super
end
end
end
我尝试触发更新的方式:
MySchema.subscriptions.trigger(:server_info,{},{ date_time: DateTime.now })
该模式定义为:
class MySchema < GraphQL::Schema
use GraphQL::Execution::Interpreter
use GraphQL::Subscriptions::ActionCableSubscriptions
subscription(Types::SubscriptionType)
end
我在config / cable.yml中将redis适配器用于开发环境:
development:
adapter: redis
url: <%= ENV.fetch("REDIS_URL") { "redis://localhost:6379/1" } %>
channel_prefix: test-app_development
我想念什么?有任何疑难解答提示吗?
更新:
一些诊断:
为初始(成功的)订阅呼叫跟踪日志:
GraphqlChannel#execute({"query"=>"subscription ServerInfoSubscription {\n serverInfo {\n dateTime\n __typename\n }\n}\n","variables"=>{},"operationName"=>"ServerInfoSubscription"})
GraphqlChannel transmitting {"data"=>{"serverInfo"=>{"dateTime"=>"2020-10-08T10:47:08-04:00","__typename"=>"ServerInfoSubscriptionPayload"}}}
GraphqlChannel is streaming from graphql-subscription:9087735b-9b99-4d66-8b77-ff3622c8efe7
GraphqlChannel is streaming from graphql-event::dateTime:
Started POST "/graphql" for 192.168.64.210 at 2020-10-08 10:47:08 -0400
检查活动的Redis PubSub频道:
$ redis-cli -h 192.168.64.210 -p 6379 pubsub channels
1) "test-app_development:graphql-subscription:9087735b-9b99-4d66-8b77-ff3622c8efe7"
2) "test-app_development:graphql-event::dateTime:"
3) "_action_cable_internal"
在Rails控制台中运行触发调用的结果:
irb(main):001:0> MySchema.subscriptions.trigger(:server_info,{ date_time: DateTime.now })
[ActionCable] Broadcasting to graphql-event::serverInfo:: "{\"date_time\":\"2020-10-08T10:54:18-04:00\",\"__sym_keys__\":[\"date_time\"]}"
最明显的是,Redis PubSub通道称为“ graphql-event :: dateTime:”,而触发调用通过不存在的“ graphql-event :: serverInfo:”通道进行广播。我不明白为什么订阅查询为顶级“ ServerInfo”类型时,实际的Redis通道为何称为“ graphql-event :: dateTime”。
解决方法
我终于让它工作了,但无法指出为什么它不起作用:
MySchema.subscriptions.trigger(:server_info,{},{ date_time: DateTime.now })
请注意,我一直在传递一个空的哈希({}
)作为第二个参数。
我可以使用的方法是在查询中添加argument
并使用匹配的参数(与原始订阅查询匹配)。像这样:
module Subscriptions
class EventReceivedSubscription < Subscriptions::BaseSubscription
argument :event_name,String,required: true
field :event_name,null: false
field :payload,null: true
end
end
MySchema.subscriptions.trigger(
:event_received,{ event_name: 'greeting' },{ payload: 'Hello' }
)
我现在看到的Redis频道是:
$ redis-cli -h 192.168.64.210 -p 6379 pubsub channels
1) "test-app_development:graphql-event::eventReceived:eventName:greeting"
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。