我正在尝试使用hubot构建一个slack bot,我需要在redis上持久化一些东西。我使用https://github.com/hubotio/hubot-redis-brain中的以下脚本
'use strict'
// Description:
// Persist hubot's brain to redis
//
// Configuration:
// REDISTOGO_URL or REDISCLOUD_URL or BOXEN_REDIS_URL or REDIS_URL.
// URL format: redis://<host>:<port>[/<brain_prefix>]
// URL format (UNIX socket): redis://<socketpath>[?<brain_prefix>]
// If not provided, '<brain_prefix>' will default to 'hubot'.
// REDIS_NO_CHECK - set this to avoid ready check (for exampel when using Twemproxy)
//
// Commands:
// None
const Url = require('url')
const Redis = require('redis')
module.exports = function (robot) {
let client, prefix
const redisUrlEnv = getRedisEnv()
const redisUrl = process.env[redisUrlEnv] || 'redis://localhost:6379'
if (redisUrlEnv) {
robot.logger.info(`hubot-redis-brain: Discovered redis from ${redisUrlEnv} environment variable`)
} else {
robot.logger.info('hubot-redis-brain: Using default redis on localhost:6379')
}
if (process.env.REDIS_NO_CHECK) {
robot.logger.info('Turning off redis ready checks')
}
const info = Url.parse(redisUrl)
if (info.hostname === '') {
client = Redis.createClient(info.pathname)
prefix = (info.query ? info.query.toString() : undefined) || 'hubot'
} else {
client = (info.auth || process.env.REDIS_NO_CHECK)
? Redis.createClient(info.port, info.hostname, {no_ready_check: true})
: Redis.createClient(info.port, info.hostname)
prefix = (info.path ? info.path.replace('/', '') : undefined) || 'hubot'
}
robot.brain.setAutoSave(false)
const getData = () =>
client.get(`${prefix}:storage`, function (err, reply) {
if (err) {
throw err
} else if (reply) {
robot.logger.info(`hubot-redis-brain: Data for ${prefix} brain retrieved from Redis`)
robot.brain.mergeData(JSON.parse(reply.toString()))
robot.brain.emit('connected')
} else {
robot.logger.info(`hubot-redis-brain: Initializing new data for ${prefix} brain`)
robot.brain.mergeData({})
robot.brain.emit('connected')
}
robot.brain.setAutoSave(true)
})
if (info.auth) {
client.auth(info.auth.split(':')[1], function (err) {
if (err) {
return robot.logger.error('hubot-redis-brain: Failed to authenticate to Redis')
}
robot.logger.info('hubot-redis-brain: Successfully authenticated to Redis')
getData()
})
}
client.on('error', function (err) {
if (/ECONNREFUSED/.test(err.message)) {
} else {
robot.logger.error(err.stack)
}
})
client.on('connect', function () {
robot.logger.debug('hubot-redis-brain: Successfully connected to Redis')
if (!info.auth) { getData() }
})
robot.brain.on('save', (data) => {
if (!data) {
data = {}
}
client.set(`${prefix}:storage`, JSON.stringify(data))
})
robot.brain.on('close', () => client.quit())
}
function getRedisEnv () {
if (process.env.REDISTOGO_URL) {
return 'REDISTOGO_URL'
}
if (process.env.REDISCLOUD_URL) {
return 'REDISCLOUD_URL'
}
if (process.env.BOXEN_REDIS_URL) {
return 'BOXEN_REDIS_URL'
}
if (process.env.REDIS_URL) {
return 'REDIS_URL'
}
}
我的问题是我不知道应该更改代码的哪个部分,以便脚本使用我的redis服务器而不是本地redis服务器。另外,我的redis服务器有一个密码作为url的一部分,我想知道把它放在哪里。谢谢您。
最佳答案
似乎没有代码更改,但可以将环境变量REDIS_URL
设置为redis实例的url。