- Kafka、Redis、Nats、ZeroMQ、RabbitMQとかのキューイングシステムの紹介
- ブローカーの有無
- メッセージのシャーディングとか
- 標準プロトコルお実装あactiveMQとRabbitMQだけ
- 独自相成りベース Kafka
#!/bin/bash | |
export HADOOP_USER_CLASSPATH_FIRST=true; | |
echo " | |
export TEZ_CONF_DIR=/etc/tez/conf | |
export TEZ_HOME=/home/hadoop/tez | |
export TEZ_JARS=/apps/tez/tez-0.4.1/*:/apps/tez/tez-0.4.1/lib/* | |
export TEZ_LOG_DIR=/home/hadoop/tez/log | |
export HADOOP_CLASSPATH=\${TEZ_CONF_DIR}:\${TEZ_JARS}/*:\${TEZ_JARS}/lib/*:\${HADOOP_CLASSPATH}" >> /home/hadoop/conf/hadoop-user-env.sh |
image: localhost/maeno/hadoop | |
script: | |
# execute unittest | |
- export PATH=$HADOOP_PREFIX/bin:$HIVE_HOME/bin:$PATH | |
- UNIT_TEST_LIST=`find ./test -name "setup.hql"|xargs -Idir dirname dir|sort -u` | |
- for u in `echo $UNIT_TEST_LIST`;do sh /tmp/run-unittest.sh ${u}; done | |
- if [ ${DRONE_BRANCH} != "master" ]; then exit 0; fi | |
- mkdir -p ~/.aws/ | |
- echo -e "[profile release]\nregion = ap-northeast-1\naws_access_key_id = $$AWS_KEY\naws_secret_access_key = $$AWS_SECRET" | tee ~/.aws/config | |
- aws --profile release s3 cp src/ s3://<s3 bucket>/hiveql/ --recursive --exclude "*" --include "*.q" |
FROM dahlb/alpine-node | |
RUN npm install twitter user-stream coffee-script | |
ADD stream stream | |
ENTRYPOINT ./node_modules/coffee-script/bin/coffee stream |
FROM ubuntu-debootstrap:14.04 | |
MAINTAINER yuki-maeno | |
RUN echo "Asia/Tokyo" > /etc/timezone && dpkg-reconfigure --frontend noninteractive tzdata \ | |
&& apt-get update \ | |
&& apt-get install --no-install-recommends -y git python python-pip liblua5.1-dev libssl-dev python-dev libevent-dev libgeoip-dev wget build-essential \ | |
&& apt-get clean \ | |
&& rm -fr /var/cache/apt/archives/* /var/lib/apt/lists/* | |
RUN wget https://pypi.python.org/packages/source/G/GeoIP/GeoIP-1.3.2.tar.gz \ | |
&& tar zxvf GeoIP-1.3.2.tar.gz \ |
package main | |
import ( | |
"fmt" | |
"io" | |
"encoding/base64" | |
"crypto/rand" | |
"crypto/cipher" | |
"crypto/aes" | |
"crypto/md5" |
#!/usr/bin/env bash | |
SCRIPT=`basename $0` | |
function usage () { | |
echo "" | |
echo "$SCRIPT -s [security group id] -a [aws cli path]" | |
echo "" | |
} |
func polling(interval, maxTime int) error { | |
ticker := time.NewTicker(time.Duration(interval) * time.Second) | |
timeout := time.NewTimer(time.Duration(maxTime) * time.Second) | |
defer timeout.Stop() | |
defer ticker.Stop() | |
for { | |
select { | |
case <-timeout.C: | |
return errors.New("timeout") | |
case <-ticker.C: |
$ git diff
diff --git a/test/test_out_s3.rb b/test/test_out_s3.rb
index 4e8438c..c7be37f 100644
--- a/test/test_out_s3.rb
+++ b/test/test_out_s3.rb
@@ -187,6 +187,22 @@ class S3OutputTest < Test::Unit::TestCase
assert_equal(expected, d.formatted)
end
mo | |
*.html |