เบฅเบปเบ”เบˆเบฑเบ. เป€เบเบฒเบฐเป€เบเบตเป‰เบ AWS

ะขะตัั‚ะธั€ะพะฒะฐะฝะธะต โ€” ัั‚ะพ ะฝะตะพั‚ัŠะตะผะปะตะผะฐั ั‡ะฐัั‚ัŒ ะฟั€ะพั†ะตััะฐ ั€ะฐะทั€ะฐะฑะพั‚ะบะธ. ะ˜ ะธะฝะพะณะดะฐ ั€ะฐะทั€ะฐะฑะพั‚ั‡ะธะบะฐะผ ั‚ั€ะตะฑัƒะตั‚ัั ะทะฐะฟัƒัั‚ะธั‚ัŒ ั‚ะตัั‚ั‹ ะปะพะบะฐะปัŒะฝะพ, ะดะพ ั‚ะพะณะพ ะผะพะผะตะฝั‚ะฐ ะบะพะผะผะธั‚ะฐ ะธะทะผะตะฝะตะฝะธะน.
ะ•ัะปะธ ะฟั€ะธะปะพะถะตะฝะธะต ะธัะฟะพะปัŒะทัƒะตั‚ Amazon Web Services, python เบซเป‰เบญเบ‡เบชเบฐเบซเบกเบธเบ” เบฅเบปเบ”เบˆเบฑเบ ะธะดะตะฐะปัŒะฝะพ ะดะปั ัั‚ะพะณะพ ะฟะพะดั…ะพะดะธั‚.
เบฅเบปเบ”เบˆเบฑเบ. เป€เบเบฒเบฐเป€เบเบตเป‰เบ AWS

ะŸะพะปะฝั‹ะน ัะฟะธัะพะบ ะฟะพะบั€ั‹ั‚ะธั ั€ะตััƒั€ัะพะฒ ะผะพะถะฝะพ ะฟะพัะผะพั‚ั€ะตั‚ัŒ เบ—เบตเปˆเบ™เบตเป‰.
ะะฐ Github ะตัั‚ัŒ ั€ะตะฟะฐ Hugo Picado - moto-server. ะ“ะพั‚ะพะฒั‹ะน ะพะฑั€ะฐะท, ะทะฐะฟัƒัะบะฐะน ะธ ะธัะฟะพะปัŒะทัƒะน. ะัŽะฐะฝั ั‚ะพะปัŒะบะพ ะฒ ั‚ะพะผ, ั‡ั‚ะพ ะฟะพัะปะต ะทะฐะฟัƒัะบะฐ, ะฝะธะบะฐะบะธั… AWS ั€ะตััƒั€ัะพะฒ ั‚ะฐะผ ะตั‰ะต ะฝะต ัะพะทะดะฐะฝะพ.

ะงั‚ะพ ะถ, ัั‚ะพ ะดะพัั‚ะฐั‚ะพั‡ะฝะพ ะปะตะณะบะพ ะธัะฟั€ะฐะฒะธั‚ัŒ.

ะŸะพัะบะพะปัŒะบัƒ ะฟั€ะธ ะทะฐะฟัƒัะบะต ะฝะตะพะฑั…ะพะดะธะผะพ ัƒะบะฐะทะฐั‚ัŒ ั‚ะธะฟ ัะตั€ะฒะธัะฐ (เบ›เบฐเบกเบฒเบ™ เบ•เบปเบงเปเบ› MOTO_SERVICE), ะฝะฐะผ ะพัั‚ะฐะตั‚ัั ะพะฟะธัะฐั‚ัŒ ัะพะทะดะฐะฝะธะต ั€ะตััƒั€ัะฐ.

ะะตะผะฝะพะณะพ ะธะทะผะตะฝะธะผ start.sh:

เปเบ—เบ™เบ—เบตเปˆเบˆเบฐ

moto_server $MOTO_SERVICE -H $MOTO_HOST -p $MOTO_PORT

ะ’ัั‚ะฐะฒะปัะตะผ:

if [ -f /opt/init/bootstrap.py ]; then
  moto_server $MOTO_SERVICE -H $MOTO_HOST -p $MOTO_PORT & (sleep 5 && echo "Executing bootstrap script." && python /opt/init/bootstrap.py)
else
  moto_server $MOTO_SERVICE -H $MOTO_HOST -p $MOTO_PORT
fi
wait

ะ˜ั‚ะพะณะพะฒั‹ะน ั„ะฐะนะป ะฟะพะปัƒั‡ะฐะตั‚ัั:

start.sh

#!/bin/sh

# validate required input
if [ -z "$MOTO_SERVICE" ]; then
  echo "Please define AWS service to run with Moto Server (e.g. s3, ec2, etc)"
  exit 1
fi

# setting defaults for optional input
if [ -z "$MOTO_HOST" ]; then
  MOTO_HOST="0.0.0.0"
fi

if [ -z "$MOTO_PORT" ]; then
  MOTO_PORT="5000"
fi

echo "Starting service $MOTO_SERVICE at $MOTO_HOST:$MOTO_PORT"

if [ -f /opt/init/bootstrap.py ]; then
  moto_server $MOTO_SERVICE -H $MOTO_HOST -p $MOTO_PORT & (sleep 5 && echo "Executing bootstrap script." && python /opt/init/bootstrap.py)
else
  moto_server $MOTO_SERVICE -H $MOTO_HOST -p $MOTO_PORT
fi
# Prevent container from exiting when bootstrap.py finishing
wait

ะ‘ะธะปะดะธะผ ะฝะพะฒั‹ะน ะพะฑั€ะฐะท ะธ ะฟัƒัˆะธะผ ะฒ ัะฒะพะน registry.

ะ”ะฐะปะตะต, ะฝะฐะฟะธัˆะตะผ ัะบั€ะธะฟั‚ ะธะฝะธั†ะธะฐะปะธะทะฐั†ะธะธ ั€ะตััƒั€ัะฐ, ะฝะฐะฟั€ะธะผะตั€ SWF domain, ะธัะฟะพะปัŒะทัƒั ะฑะธะฑะปะธะพั‚ะตะบัƒ ะดะปั ั€ะฐะฑะพั‚ั‹ ั AWS โ€” boto3:

bootstrap_swf.py

import boto3
from botocore.exceptions import ClientError
import os

os.environ["AWS_ACCESS_KEY_ID"] = "fake"
os.environ["AWS_SECRET_ACCESS_KEY"] = "fake"

client = boto3.client('swf', region_name='us-west-2', endpoint_url='http://localhost:5000')

try:
    client.register_domain(
        name='test-swf-mock-domain',
        description="Test SWF domain",
        workflowExecutionRetentionPeriodInDays="10"
    )
except ClientError as e:
    print "Domain already exists: ", e.response.get("Error", {}).get("Code")

response = client.list_domains(
    registrationStatus='REGISTERED',
    maximumPageSize=123,
    reverseOrder=True|False
)

print 'Ready'

ะ›ะพะณะธะบะฐ ั‚ะฐะบะฐั:

  • ะœะพะฝั‚ะธั€ัƒะตะผ ะฟั€ะธ ะทะฐะฟัƒัะบะต ะฝะฐัˆ ัะบั€ะธะฟั‚ ะฒ /opt/init/bootstrap.py.
  • ะ•ัะปะธ ั„ะฐะนะป ะฟั€ะธะผะพะฝั‚ะธั€ะพะฒะฐะฝ โ€” ะพะฝ ะฑัƒะดะตั‚ ะฒั‹ะฟะพะปะฝะตะฝ.
  • ะ•ัะปะธ ั„ะฐะนะปะฐ ะฝะตั‚ โ€” ะฟั€ะพัั‚ะพ ะทะฐะฟัƒัั‚ะธั‚ัั ะณะพะปั‹ะน moto-server.

ะ˜, ะผะพะถะฝะพ ะผะพะบะฐั‚ัŒ ั†ะตะปั‹ะน ั€ะตััƒั€ั ะทะฐะฟัƒัะบะพะผ ะพะดะฝะพะณะพ ะบะพะฝั‚ะตะนะฝะตั€ะฐ:

docker run --name swf -d 
    -e MOTO_SERVICE=swf 
    -e MOTO_HOST=0.0.0.0 
    -e MOTO_PORT=5000 
    -p 5001:5000 
    -v /tmp/bootstrap_swf.py:/opt/init/bootstrap.py 
    -i awesome-repo.com/moto-server:latest

ะŸั€ะพะฑัƒะตะผ ะฒ ะธะฝั‚ะตั€ะฐะบั‚ะธะฒะฝะพะผ ั€ะตะถะธะผะต:

เบฅเบปเบ”เบˆเบฑเบ. เป€เบเบฒเบฐเป€เบเบตเป‰เบ AWS

ะฐะฑะพั‚ะฐะตั‚!

ะขะฐะบะธะผ ะพะฑั€ะฐะทะพะผ, ะผั‹ ะผะพะถะตะผ ัะดะตะปะฐั‚ัŒ docker-compose.yml, ะบะพั‚ะพั€ั‹ะน ะฟะพะผะพะถะตั‚ ััะบะพะฝะพะผะธั‚ัŒ ะฒั€ะตะผั ะฝะฐ ั‚ะตัั‚ะธั€ะพะฒะฐะฝะธะต ะธะทะผะตะฝะตะฝะธะน:

docker-compose.yml

version: '3'
services:
  s3:
    image: picadoh/motocker
    environment:
      - MOTO_SERVICE=s3
      - MOTO_HOST=10.0.1.2
    ports:
      - "5002:5000"
    networks:
      motonet:
        ipv4_address: 10.0.1.2
    volumes:
      - /tmp/bootstrap_s3.py:/opt/init/bootstrap.py
  swf:
    image: picadoh/motocker
    environment:
      - MOTO_SERVICE=swf
      - MOTO_HOST=10.0.1.3
    ports:
      - "5001:5000"
    networks:
      motonet:
        ipv4_address: 10.0.1.3
    volumes:
      - /tmp/bootstrap_swf.py:/opt/init/bootstrap.py
  ec2:
    image: picadoh/motocker
    environment:
      - MOTO_SERVICE=ec2
      - MOTO_HOST=10.0.1.4
    ports:
      - "5003:5000"
    networks:
      motonet:
        ipv4_address: 10.0.1.4
    volumes:
      - /tmp/bootstrap_ec2.py:/opt/init/bootstrap.py
networks:                             
  motonet:                          
    driver: bridge                
    ipam:                         
      config:                       
        - subnet: 10.0.0.0/16

ะกะพะฑัั‚ะฒะตะฝะฝะพ, ะฝะต ั‚ะพะปัŒะบะพ ะปะธัˆัŒ ะฝะฐ ะฝะพัƒั‚ะฑัƒะบะต ั€ะฐะทั€ะฐะฑะพั‚ั‡ะธะบะฐ ะผะพะถะฝะพ ะธัะฟะพะปัŒะทะพะฒะฐั‚ัŒ ั‚ะฐะบะพะน ะฟะพะดั…ะพะด. ะŸั€ะตะดะฒะฐั€ะธั‚ะตะปัŒะฝั‹ะต ั‚ะตัั‚ั‹ ั ะผะพะบะฐะผะธ ะฟะพัะปะต ัะฑะพั€ะบะธ, ะฟะพะผะพะณัƒั‚ ะธะทะฑะฐะฒะธั‚ัŒัั ะพั‚ ะฒะพะทะผะพะถะฝั‹ั… ะฟั€ะพะฑะปะตะผ ะฟั€ะธ ะทะฐะฟัƒัะบะต ะฝะฐ dev* ะพะบั€ัƒะถะตะฝะธัั….

เป€เบญเบเบฐเบชเบฒเบ™เบญเป‰เบฒเบ‡เบญเบตเบ‡:

Motocker repo โ€” github.com/picadoh/motocker
Moto repo โ€” github.com/spulec/moto
Boto3 Docs โ€” boto3.amazonaws.com/v1/documentation/api/latest/index.html

เปเบซเบผเปˆเบ‡เบ‚เปเป‰เบกเบนเบ™: www.habr.com

เป€เบžเบตเปˆเบกเบ„เบงเบฒเบกเบ„เบดเบ”เป€เบซเบฑเบ™