【发布时间】:2019-12-26 01:36:43
【问题描述】:
我们在节点 graphql 服务器上使用订阅。最近我添加了集群能力,并使用 Redis 进行 pubsub。在我当地的环境中,一切都很好。当我第一次上传到 heroku 并使用他们的 Redis 插件时,我看到它显示了一个突变,但下一次却没有。几次尝试后,它再次工作(50% 工作)。
import { RedisPubSub } from 'graphql-redis-subscriptions';
import Redis from 'ioredis';
let REDIS_URL = process.env.REDIS_URL || 'redis://127.0.0.1:6379';
const options = {
retryStrategy: times => {
// reconnect after
return Math.min(times * 50, 2000);
}
};
const pubsub = new RedisPubSub({
publisher: new Redis(REDIS_URL, options),
subscriber: new Redis(REDIS_URL, options)
});
这是我在日志中得到的错误
Aug 22 16:06:11 service-staging app[web] Error (node:76) UnhandledPromiseRejectionWarning: Error: Connection in subscriber mode, only subscriber commands may be used
Aug 22 16:06:11 service-staging app[web] info at Redis.sendCommand (/app/node_modules/ioredis/built/redis/index.js:570:24)
Aug 22 16:06:11 service-staging app[web] info at DatastoreShim.applySegment (/app/node_modules/newrelic/lib/shim/shim.js:1424:20)
Aug 22 16:06:11 service-staging app[web] info at _applyRecorderSegment (/app/node_modules/newrelic/lib/shim/shim.js:1015:20)
Aug 22 16:06:11 service-staging app[web] info at Redis._doRecord (/app/node_modules/newrelic/lib/shim/shim.js:994:17)
Aug 22 16:06:11 service-staging app[web] info at Redis.wrapper [as sendCommand] (/app/node_modules/newrelic/lib/shim/shim.js:965:24)
Aug 22 16:06:11 service-staging app[web] info at Redis.publish (/app/node_modules/ioredis/built/commander.js:124:21)
Aug 22 16:06:11 service-staging app[web] info at RedisPubSub.<anonymous> (/app/node_modules/graphql-redis-subscriptions/src/redis-pubsub.ts:64:31)
Aug 22 16:06:11 service-staging app[web] info at step (/app/node_modules/graphql-redis-subscriptions/dist/redis-pubsub.js:32:23)
Aug 22 16:06:11 service-staging app[web] info at Object.next (/app/node_modules/graphql-redis-subscriptions/dist/redis-pubsub.js:13:53)
Aug 22 16:06:11 service-staging app[web] info at /app/node_modules/graphql-redis-subscriptions/dist/redis-pubsub.js:7:71
Aug 22 16:06:11 service-staging app[web] info at new Promise (<anonymous>)
Aug 22 16:06:11 service-staging app[web] info at __awaiter (/app/node_modules/graphql-redis-subscriptions/dist/redis-pubsub.js:3:12)
Aug 22 16:06:11 service-staging app[web] info at RedisPubSub.publish (/app/node_modules/graphql-redis-subscriptions/dist/redis-pubsub.js:76:16)
Aug 22 16:06:11 service-staging app[web] info at publish (/app/src/resolvers/action.js:435:18)
Aug 22 16:06:11 service-staging app[web] info (node:76) UnhandledPromiseRejectionWarning: Unhandled promise rejection. This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). (rejection id: 9)
当我运行突变时,我应该会看到它出现在监听订阅中。
另外,附带说明一下,如果我将实例数设置为 1 或 2,我总是会收到错误消息。 3个或更多我至少得到第一个突变和以下突变的一半。
【问题讨论】:
-
您好,欢迎来到 Stack Overflow!您能否添加错误/控制台日志和任何其他上下文,以便我们更好地帮助您?谢谢!
标签: heroku redis graphql publish-subscribe