This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
wyatt@mac:nsq/src $ ruby producer.rb | |
SizeQueue: 2495 | |
SizeQueue: 4947 | |
SizeQueue: 7446 | |
SizeQueue: 9999 | |
SizeQueue: 9891 | |
SizeQueue: 10000 | |
SizeQueue: 10000 | |
SizeQueue: 10000 | |
SizeQueue: 9916 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# statsd & graphite | |
sg: docker run --name graphite --rm -p 80:80 -p 2003-2004:2003-2004 -p 2023-2024:2023-2024 -p 8125:8125/udp -p 8126:8126 hopsoft/graphite-statsd | |
# nsqdlookupd http:4161, tcp:4160 | |
nsqdlookupd: nsqlookupd | |
# nsqd http:4151, https: 4152, tcp: 4150 | |
nsqd: nsqd -lookupd-tcp-address=127.0.0.1:4160 -mem-queue-size=0 -broadcast-address=127.0.0.1 -statsd-address="127.0.0.1:8125" -statsd-interval="10s" | |
nsqd2: nsqd -lookupd-tcp-address=127.0.0.1:4160 -mem-queue-size=0 -tcp-address=0.0.0.0:4250 -http-address=0.0.0.0:4251 -https-address=0.0.0.0:4252 -data-path=./nsqd2 -broadcast-address=127.0.0.1 -statsd-address="127.0.0.1:8125" -statsd-interval="10s" |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
require 'bundler' | |
require 'active_model_serializers' | |
require 'roar/decorator' | |
require 'roar/json' | |
require 'rabl' | |
require 'jbuilder' | |
require 'benchmark' | |
require 'ffaker' | |
require 'multi_json' | |
require 'oj' |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
require 'capybara' | |
require 'selenium-webdriver' | |
require 'thread/pool' | |
pool = Thread.pool(3) | |
Capybara.threadsafe = true | |
Capybara.default_driver = :selenium_chrome | |
#Capybara.default_driver = :selenium_chrome_headless |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
baf5 url="https://www.amazon.com/product-reviews/B0018OPL7O/ref=cm_cr_arp_d_viewopt_rvwer?ie=UTF8&reviewerType=all_reviews&pageSize=50&sortBy=recent&filterByStar=all_stars" | |
fatal error: concurrent map read and map write | |
goroutine 717 [running]: | |
runtime.throw(0xb22bc8, 0x21) | |
/usr/local/Cellar/go/1.9/libexec/src/runtime/panic.go:605 +0x95 fp=0xc420982608 sp=0xc4209825e8 pc=0x42a375 | |
runtime.mapaccess2(0xa47860, 0xc420454390, 0xc420df3410, 0xa02be0, 0x4dfcc4) | |
/usr/local/Cellar/go/1.9/libexec/src/runtime/hashmap.go:413 +0x24e fp=0xc420982650 sp=0xc420982608 pc=0x40847e | |
reflect.mapaccess(0xa47860, 0xc420454390, 0xc420df3410, 0xc420454390) | |
/usr/local/Cellar/go/1.9/libexec/src/runtime/hashmap.go:1218 +0x3f fp=0xc420982688 sp=0xc420982650 pc=0x40ad9f |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
``` | |
DEBU[2017-10-13 08:06:41] discover_review_task.poster 任务结束 duration=0.394015634 jid=28b25547b9b04da8ef051d39 job=discover_review_task.poster slow=false source="/jobs/context.go[38]: jobs.(*Context).logDuration" | |
fatal error: concurrent map writes | |
goroutine 1096 [running]: | |
runtime.throw(0xb1aad8, 0x15) | |
/usr/local/Cellar/go/1.9/libexec/src/runtime/panic.go:605 +0x95 fp=0xc420f46ac8 sp=0xc420f46aa8 pc=0x42a375 | |
runtime.mapassign_faststr(0xa47860, 0xc42178e120, 0xb11b22, 0x3, 0x3) | |
/usr/local/Cellar/go/1.9/libexec/src/runtime/hashmap_fast.go:607 +0x4f5 fp=0xc420f46b48 sp=0xc420f46ac8 pc=0x40cc65 | |
ear-monitor/models.(*taskRouter).Rule(0xc4201bd840, 0xc4222da480, 0xc420f46d00, 0xc420f46d08, 0xc421ee2580) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
[ | |
{ | |
"tid": "0068fbe3-bd16-43d5-bfe1-cd0a940fd013", | |
"url": "https://www.amazon.es/product-reviews/B01G1D7ID6/ref=cm_cr_arp_d_viewopt_srt?ie=UTF8&filterByStar=all_stars&pageNumber=1&pageSize=50&sortBy=recent", | |
"callback": "http://44c74ebf.ngrok.io/api/v1/echo", | |
"rules": [ | |
{ | |
"scope_rule": "//*[@id='cm_cr-review_list']/div[contains(@class,'review')]", | |
"kv_rule": [ | |
{ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
[ | |
{ | |
"tid": "0162d346-dae0-40a3-b0c3-8aa1fa312870", | |
"url": "https://www.amazon.de/product-reviews/B01I94NJ1U/ref=cm_cr_arp_d_viewopt_srt?ie=UTF8&filterByStar=all_stars&pageNumber=1&pageSize=50&sortBy=recent", | |
"callback": "http://44c74ebf.ngrok.io/api/v1/echo", | |
"rules": [ | |
{ | |
"scope_rule": "//*[@id='cm_cr-review_list']/div[contains(@class,'review')]", | |
"kv_rule": [ | |
{ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
[ | |
{ | |
"tid": "04e9d161-5139-406c-b9ff-e2f96e37a3c5", | |
"url": "https://www.amazon.ca/product-reviews/B015O9O5D4/ref=cm_cr_arp_d_viewopt_srt?ie=UTF8&filterByStar=all_stars&pageNumber=1&pageSize=50&sortBy=recent", | |
"callback": "http://44c74ebf.ngrok.io/api/v1/echo", | |
"rules": [ | |
{ | |
"scope_rule": "//*[@id='cm_cr-review_list']/div[contains(@class,'review')]", | |
"kv_rule": [ | |
{ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
X-Alimail-AntiSpam:AC=SPAM;BC=0.9200199|0.8529158;BR=01201311R951b1;FP=0|0|0|0|0|-1|-1|-1;HT=e02c03308;MF=rte+ne-null-b1cb1a0678232epoxisg1c7dr@sellernotifications.amazon.com;NM=1;PH=DM;RN=1;RT=1;SC=102.3;SR=6;TI=MTA_---.7fVm9dC_1487574683; | |
Received: from a1-235.smtp-out.eu-west-1.amazonses.com(mailfrom:RTE+NE-null-b1cb1A0678232EPOXISG1C7DR@sellernotifications.amazon.com ip:54.240.1.235) | |
by mx1.aliyun-inc.com(10.147.42.34); | |
Mon, 20 Feb 2017 15:11:26 +0800 | |
DKIM-Signature: v=1; a=rsa-sha256; q=dns/txt; c=relaxed/simple; | |
s=yqjhwsipgo3kjycfsffiutnhfur6rrw6; d=amazon.es; t=1487574670; | |
i=@marketplace.amazon.es; | |
h=Date:From:Reply-To:To:Message-ID:Subject:MIME-Version:Content-Type; | |
bh=RukVGddkhEQujy9d3mm8dHWExq09y+CqL32FcQtaKC8=; | |
b=GteVz1AZ8NRMBDi0hqoSo4oW5keLPOOYP9Xby5OSR+sfpjRJfFGk1sUOBJSNwpKB |