小编Jor*_*ein的帖子

我是组织中唯一一个使用以下消息进行提交的人:

将远程跟踪分支'origin/develop'合并到develop中

不知道我在做什么导致他们,但我想停下来.

我发出什么命令来创建这个提交,我应该用什么命令来生成它？

Rabbitmq服务器无法启动,说它已经运行:

$: rabbitmq-server
Activating RabbitMQ plugins ...
0 plugins activated:

node with name "rabbit" already running on "android-d1af002161676bee"
diagnostics:
- nodes and their ports on android-d1af002161676bee: [{rabbit,52176},
                                                      {rabbitmqprelaunch2254,
                                                       59205}]
- current node: 'rabbitmqprelaunch2254@android-d1af002161676bee'
- current node home dir: /Users/Jordan
- current node cookie hash: ZSx3slRJURGK/nHXDTBRqQ==

Run Code Online (Sandbox Code Playgroud)

但是,rabbitmqctl似乎不这么认为:

rabbitmqctl -n rabbit status
Status of node 'rabbit@android-d1af002161676bee' ...
Error: unable to connect to node 'rabbit@android-d1af002161676bee': nodedown
diagnostics:
- nodes and their ports on android-d1af002161676bee: [{rabbit,52176},
                                                      {rabbitmqctl2462,59256}]
- current node: 'rabbitmqctl2462@android-d1af002161676bee'
- current …

Run Code Online (Sandbox Code Playgroud)

是否有使用ES6或ES7或babel的语法,这将允许我轻松地将许多子文件组捆绑在一起？

例如,给出:

./action_creators/index.js
./action_creators/foo_actions.js
./action_creators/bar_actions.js

让index.js导入foo和bar动作,然后重新导出它们,所以我可以

import {FooAction, BarAction} from './action_creators/index.js'

如果我要更改我自己组织对象的文件,我不想记住/更改引用.

在我的ActionMailer :: TestCase测试中,我期待:

@expected.to      = BuyadsproMailer.group_to(campaign.agency.users)
@expected.subject = "You submitted #{offer_log.total} worth of offers for #{offer_log.campaign.name} "
@expected.from    = "BuyAds Pro <feedback@buyads.com>"
@expected.body    = read_fixture('deliver_to_agency')

@expected.content_type = "multipart/mixed;\r\n boundary=\"something\""
@expected.attachments["#{offer_log.aws_key}.pdf"] = {
  :mime_type => 'application/pdf',
  :content => fake_pdf.body
}

并将我的邮件发送给我以获取fake_pdf,而不是通常从S3获取的真实PDF,以便我确定PDF的正文匹配.

但是,我收到这个长时间的错误,告诉我一封电子邮件是预期的,但收到的电子邮件略有不同:

<...Mime-Version: 1.0\r\nContent-Type: multipart/mixed\r\nContent-Transfer-Encoding: 7bit...> expected but was
<...Mime-Version: 1.0\r\nContent-Type: multipart/mixed;\r\n boundary=\"--==_mimepart_50f06fa9c06e1_118dd3fd552035ae03352b\";\r\n charset=UTF-8\r\nContent-Transfer-Encoding: 7bit...>

我不匹配生成的电子邮件的字符集或部分边界.

如何定义或存储我预期的电子邮件的这一方面？

我正在尝试向列中添加行,将order最新列设置为1,并将所有其他行从那里开始计数.

在这种情况下,我添加一个order = 0的新行,然后使用此查询将所有行更新为1.

"UPDATE favorits SET order = order+1"

但是,所发生的是所有行都更新为相同的值.我得到了一堆收藏夹,例如订单6,当它应该是一个1时,下一个带2,依此类推.

如何更新这些行的方式按照它们的方式对它们进行排序？

谢谢,
〜乔丹

$: which node
$: node
-bash: node: command not found
$: brew install node
Error: node-0.6.18 already installed
$: brew doctor
Error: You have unlinked kegs in your Cellar
Leaving kegs unlinked can lead to build-trouble and cause brews that depend on
those kegs to fail to run properly once built.

node

$: brew link node
Error: No such file or directory - /usr/local/Cellar/node/0.6.5
$: brew uninstall node
Error: No such file or directory - /usr/local/Cellar/node/0.6.5
$: brew install node …

我正在从远程源读取数据,偶尔会在另一个编码中获取一些字符.它们并不重要.

我想获得一个"最佳猜测"utf-8字符串,并忽略无效数据.

主要目标是获取我可以使用的字符串,而不是遇到如下错误:

• 编码:: UndefinedConversionError:"\ xFF"从ASCII-8BIT到UTF-8:
• utf-8中的字节序列无效

我希望我的订单模型的ID从1000开始,并从那里自动递增计数.

这可以通过迁移来完成吗？

DelayedJob文档提到了钩子,包括一个错误钩子,但只在自定义Job子类的上下文中.

这个类似的问题(没有答案)说,在邮件程序类中添加相同的钩子不起作用.

有什么诀窍？

更新:

一般来说,我想看看如何为使用object.delay.action()语法触发的作业添加钩子,我没有看到明显的____Job类链接.

在与Google的一位朋友交谈后,我想实现某种Job/Worker模型来更新我的数据集.

此数据集镜像第三方服务的数据,因此,要进行更新,我需要对其API进行多次远程调用.我认为将花费大量时间等待第三方服务的回复.我想加快速度,更好地利用我的计算时间,通过并行化这些请求并同时保持其中许多请求,等待他们的个人响应.

在我解释我的特定数据集并解决问题之前,我想澄清一下我正在寻找的答案:

1. 这是一个非常适合与MapReduce并行化的流程吗？
2. 如果是的话,在亚马逊的mapreduce模块上运行是否具有成本效益,该模块按小时计费,并在作业完成时向上计算小时数？(我不确定究竟什么算作"工作",所以我不确切知道我将如何收费)
3. 如果不是,我应该使用另一种系统/模式吗？和是否有一个库,这将有助于我在Python做到这一点(在AWS上,usign EC2 + EBS)？
4. 我在设计这个工作流程时遇到了什么问题？

好的,现在进入细节:

数据集由拥有最喜欢的项目并跟随其他用户的用户组成.目的是能够更新每个用户的队列 - 用户在加载页面时将看到的项目列表,基于她所关注的用户的最喜欢的项目.但是,在我可以处理数据并更新用户队列之前,我需要确保拥有最新的数据,这是API调用的来源.

我可以拨打两个电话:

• 获取关注用户 - 返回所请求用户所遵循的所有用户,以及
• 获取收藏的项目 - 返回所请求用户的所有喜爱的项目.

在我打电话给跟随用户更新用户之后,我需要为每个被关注的用户更新喜欢的项目.仅当为所有被跟踪的用户返回所有收藏夹时,才能开始处理该原始用户的队列.此流程如下:

此流程中的工作包括:

• 开始为用户更新队列 - 通过提取用户,然后更新用户,存储它们,然后为每个用户创建获取收藏夹作业来启动流程.
• 获取用户的收藏夹 - 来自第三方服务的请求和存储,指定用户的收藏夹列表.
• 为用户计算新队列 - 现在已经获取了所有数据,处理新队列,然后将结果存储在应用程序层使用的缓存中.

所以,我的问题是:

1. 这是一个非常适合与MapReduce并行化的流程吗？我不知道它是否会让我启动UserX的进程,获取所有相关数据,并在完成所有操作后返回处理UserX的队列.
2. 如果是的话,在亚马逊的mapreduce模块上运行是否具有成本效益,该模块按小时计费,并在作业完成时向上计算小时数？如果我使用他们的模块,我有多少"线程"可以等待开放的API请求？
3. 如果不是,我应该使用另一种系统/模式吗？和是否有一个库,这将有助于我在Python做到这一点(在AWS上,usign EC2 + EBS？)？
4. 我在设计这个工作流程时遇到了什么问题？

感谢阅读,我期待与大家进行一些讨论.

编辑,以回应JimR:

谢谢你的回复.在我写完原始问题后的阅读中,我已经倾向于使用MapReduce了.我还没有确定如何构建它,但我开始觉得MapReduce更适合分发/并行化计算负载,而我真的只是想要并行化HTTP请求.

什么是我的"减少"任务,即获取所有获取数据并将其压缩成结果的部分,并不是计算密集型的.我很确定它会成为一个大的SQL查询,每个用户执行一两秒钟.

所以,我倾向于:

• 用Python编写的非MapReduce Job/Worker模型.我的一个谷歌朋友让我为此学习Python,因为它的开销很低,并且可以很好地扩展.
• 使用Amazon EC2作为计算层.我想这意味着我还需要一个EBS切片来存储我的数据库.
• 可能使用亚马逊的简单消息队列.听起来这个第三个亚马逊小部件旨在跟踪作业队列,将结果从一个任务移动到另一个任务的输入,并优雅地处理失败的任务.它很便宜.可能值得实现而不是自定义作业队列系统.