Switch branches/tags
Nothing to show
Find file Copy path
Fetching contributors…
Cannot retrieve contributors at this time
132 lines (111 sloc) 5.62 KB
#!/usr/bin/env python2.7
# Copyright 2015, Inc. or its affiliates. All Rights Reserved.
# Licensed under the Amazon Software License (the "License"). You may not use this file except in compliance with the
# License. A copy of the License is located at
# or in the "LICENSE.txt" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES
# OR CONDITIONS OF ANY KIND, express or implied. See the License for the specific language governing permissions and
# limitations under the License.
# ---------------------------------------------------------------------------------------------------------------------
# uses AWS CLI tools to obtain price history for the last week (by default),
# and prints time duration since the last time Spot price exceeded the bid price.
# We use CLI for simplicity and demonstration purposes. For production code please use SDK/boto3
# Input: product-description, region, and combination of instance types and Spot bids prices for each instance type.
# Example:
# $ python -r us-east-1 -b c3.large:0.105,c3.xlarge:0.210 \
# --product-description 'Linux/UNIX (Amazon VPC)'
# v0.1
import argparse
from argparse import RawTextHelpFormatter
import calendar
import json
import sys
import datetime
import time
from subprocess import Popen, PIPE
# Call AWS CLI and obtain JSON output, we could've also used tabular or text, but json is easier to parse.
def make_call(cmdline, profile):
cmd_args = ['aws', '--output', 'json'] + (['--profile', profile] if profile else []) + cmdline
p = Popen(cmd_args, stdout=PIPE)
res, _ = p.communicate()
res = res.decode('utf-8')
if p.wait() != 0:
sys.stderr.write("Failed to execute: " + " ".join(cmd_args))
if not res:
return {}
return json.loads(res)
def iso_to_unix_time(iso):
return calendar.timegm(time.strptime(iso, '%Y-%m-%dT%H:%M:%S.%fZ'))
# For each availability zone, return timestamp of the last time Spot price exceeded specified bid price
def get_last_spot_price_exceeding_the_bid(profile, hours, inst_type, region, product, bid):
now = datetime.datetime.utcfromtimestamp(time.time())
start_time = now - datetime.timedelta(hours=hours)
start_time_unix = calendar.timegm(start_time.utctimetuple())
#: :type: list of SpotPriceHistory
res = make_call(["ec2", "--region", region,
"--start-time", start_time.isoformat(),
"--end-time", now.isoformat(),
"--instance-types", inst_type,
"--product-descriptions", product], profile)
last_times = {}
for p in res['SpotPriceHistory']:
cur_ts = iso_to_unix_time(p['Timestamp'])
cur_az = p['AvailabilityZone']
old_ts = last_times.get((inst_type, cur_az), None)
if old_ts is None:
last_times[(inst_type, cur_az)] = old_ts = start_time_unix
if float(p['SpotPrice']) > bid and cur_ts > old_ts:
last_times[(inst_type, cur_az)] = cur_ts
return last_times
parser = argparse.ArgumentParser(
description=" - order capacity pools based on duration since the last time "
"the spot price exceeded the bid price.",
epilog="Output: tab-separated list of (duration_in_hours, instance_type, availability_zone) tuples\n\n"
"./ -r us-east-1 -b c3.large:0.105,c3.xlarge:0.210 \ \n"
" --product-description 'Linux/UNIX (Amazon VPC)'")
parser.add_argument("-r", "--region", help="AWS region (e.g.: us-east-1)", dest="region", required=True)
parser.add_argument("--profile", help="AWS CLI tools profile", dest="profile", default=None)
parser.add_argument("--hours", dest="hours", type=int, default=7*24, help="The period to check, in hours. Default is 1 week.")
product_choices = ["Linux/UNIX", "SUSE Linux", "Windows",
"Linux/UNIX (Amazon VPC)", "SUSE Linux (Amazon VPC)",
"Windows (Amazon VPC)"]
parser.add_argument("--product-description","-p", help='EC2 Product Type in double quotes (e.g.: "Linux/UNIX (Amazon VPC)")', type=str,
choices=product_choices, dest="product")
parser.add_argument("--bids", "-b",help="Comma-separated list of instance types and bids: Instance_type:bid,"
" example: c3.2xlarge:1,c3.4xlarge:2", required=True, dest="list_of_spot_bids")
args = parser.parse_args()
if args.product is None:
sys.stderr.write("No product specified out of the list of supported options: %s\n" % (", ".join(product_choices)))
types = {}
for it in args.list_of_spot_bids.split(","):
parts = it.split(":")
if len(parts) != 2:
sys.stderr.write("Instance type '%s' is malformed. It needs to include "
"instance type and bid, e.g. c3.2xlarge:1.0\n" % it)
types[parts[0]] = float(parts[1])
except TypeError:
sys.stderr.write("Price '%s' is malformed, should be a floating point number.\n" % parts[1])
result = {}
for it, bid in types.items():
result.update(get_last_spot_price_exceeding_the_bid(args.profile, args.hours, it, args.region, args.product, bid))
unix_now = time.time()
sorted_list = list(result.keys())
sorted_list.sort(key=lambda x: (result.get(x, 0), x))
print("Duration\tInstance Type\tAvailability Zone")
for it in sorted_list:
date = result.get(it, 0)
print("%.1f\t%s\t%s" % ((unix_now - date)/3600.0, it[0], it[1]))