Java 类com.amazonaws.services.ec2.model.AvailabilityZone 实例源码

项目：soundwave 文件：Ec2InstanceStore.java

@Override
public Map<AvailabilityZone, List<Instance>> getInstancesMapForZone(
    AvailabilityZone zone, AmazonEC2Client client) throws Exception {

  OperationStats op = new OperationStats("ec2InstanceStore", "getInstancesMapForZone");

  try {
    Map<AvailabilityZone, List<Instance>> ret = new HashMap<>();
    ret.put(zone, getInstancesForZone(zone, client));

    op.succeed();
    return ret;

  } catch (Exception e) {

    op.failed();
    logger.error(ExceptionUtils.getRootCauseMessage(e));
    throw e;
  }
}

项目：soundwave 文件：Ec2InstanceStore.java

@Override
public Map<AvailabilityZone, List<ReservedInstances>> getReservedInstancesForZone(
    AvailabilityZone zone, AmazonEC2Client client) throws Exception {

  OperationStats op = new OperationStats("ec2InstanceStore", "getReservedInstancesForZone");

  try {
    Map<AvailabilityZone, List<ReservedInstances>> ret = new HashMap<>();
    DescribeReservedInstancesRequest request = new DescribeReservedInstancesRequest()
        .withFilters(new Filter("availability-zone", Arrays.asList(zone.getZoneName())))
        .withSdkClientExecutionTimeout(
            600 * 1000) //10 minutes time out for total execution including retries
        .withSdkRequestTimeout(300 * 1000); //5 minutes time out for a single request

    DescribeReservedInstancesResult result = client.describeReservedInstances(request);
    ret.put(zone, result.getReservedInstances());

    op.succeed();
    return ret;

  } catch (Exception e) {

    op.failed();
    logger.error(ExceptionUtils.getRootCauseMessage(e));
    throw e;
  }
}

项目：photon-model 文件：AWSEnumerationAndCreationAdapterService.java

@Override
public void handleSuccess(DescribeAvailabilityZonesRequest request,
        DescribeAvailabilityZonesResult result) {

    List<AvailabilityZone> zones = result.getAvailabilityZones();
    if (zones == null || zones.isEmpty()) {
        this.service
                .logFine(() -> "No AvailabilityZones found. Nothing to be created locally");
        this.context.refreshSubStage = this.next;
        this.service.processRefreshSubStages(this.context);
        return;
    }

    loadLocalResources(this.service, this.context,
            zones.stream()
                    .map(AvailabilityZone::getZoneName)
                    .collect(Collectors.toList()),
            cm -> createMissingLocalInstances(zones, cm),
            cm -> {
                this.service.logFine(() -> "No AvailabilityZones found. Nothing to be"
                        + " created locally");
                this.context.refreshSubStage = this.next;
                this.service.processRefreshSubStages(this.context);
            });
}

项目：photon-model 文件：AWSEnumerationAndCreationAdapterService.java

private ComputeDescription createComputeDescription(AvailabilityZone z) {
    ComputeDescriptionService.ComputeDescription cd = Utils
            .clone(this.context.parentCompute.description);
    cd.supportedChildren = new ArrayList<>();
    cd.supportedChildren.add(ComputeType.VM_GUEST.toString());
    cd.documentSelfLink = null;
    cd.id = z.getZoneName();
    cd.zoneId = z.getZoneName();
    cd.name = z.getZoneName();
    cd.regionId = z.getRegionName();
    cd.endpointLink = this.context.request.original.endpointLink;
    if (cd.endpointLinks == null) {
        cd.endpointLinks = new HashSet<>();
    }
    cd.computeHostLink = this.context.request.parentCompute.documentSelfLink;
    cd.endpointLinks.add(this.context.request.original.endpointLink);
    // Book keeping information about the creation of the compute description in the system.
    if (cd.customProperties == null) {
        cd.customProperties = new HashMap<>();
    }
    cd.customProperties.put(SOURCE_TASK_LINK,
            ResourceEnumerationTaskService.FACTORY_LINK);

    return cd;
}

项目：cerberus-lifecycle-cli 文件：Ec2ServiceTest.java

@Test
public void testGetAvailabilityZones() {

    String zoneName = "zone-name";

    when(ec2Client.describeAvailabilityZones()).thenReturn(
            new DescribeAvailabilityZonesResult()
                    .withAvailabilityZones(
                            new AvailabilityZone()
                                    .withZoneName(zoneName)
                                    .withState(AvailabilityZoneState.Available),
                            new AvailabilityZone()
                                    .withZoneName("not-available-zone")
                                    .withState(AvailabilityZoneState.Unavailable)
                    )
    );

    // invoke method under test
    List<String> results = ec2Service.getAvailabilityZones();

    assertEquals(1, results.size());
    assertEquals(zoneName, results.get(0));
}

项目：herd 文件：EmrPricingHelper.java

/**
 * Returns a mapping of instance types to on-demand prices for the given AZ and instance types. The on-demand prices are retrieved from database
 * configurations. The on-demand prices are looked up by the AZ's region name. This method also validates that the given instance types are real instance
 * types supported by AWS.
 *
 * @param availabilityZone the availability zone of the on-demand instances
 * @param instanceTypes the sizes of the on-demand instances
 *
 * @return the map of instance type to on-demand price
 * @throws ObjectNotFoundException when any of the instance type was not found in the given region
 */
private Map<String, BigDecimal> getInstanceTypeOnDemandPrices(AvailabilityZone availabilityZone, Set<String> instanceTypes)
{
    Map<String, BigDecimal> instanceTypeOnDemandPrices = new HashMap<>();
    for (String instanceType : instanceTypes)
    {
        Ec2OnDemandPricingEntity onDemandPrice = ec2OnDemandPricingDao.getEc2OnDemandPricing(availabilityZone.getRegionName(), instanceType);

        if (onDemandPrice == null)
        {
            throw new ObjectNotFoundException(
                "On-demand price for region '" + availabilityZone.getRegionName() + "' and instance type '" + instanceType + "' not found.");
        }

        instanceTypeOnDemandPrices.put(instanceType, onDemandPrice.getHourlyPrice());
    }

    return instanceTypeOnDemandPrices;
}

项目：herd 文件：Ec2DaoImpl.java

/**
 * This implementation uses the DescribeAvailabilityZones API to get the list of AZs.
 */
@Override
public List<AvailabilityZone> getAvailabilityZonesForSubnetIds(Collection<Subnet> subnets, AwsParamsDto awsParamsDto)
{
    Set<String> zoneNames = new HashSet<>();
    for (Subnet subnet : subnets)
    {
        zoneNames.add(subnet.getAvailabilityZone());
    }

    AmazonEC2Client ec2Client = getEc2Client(awsParamsDto);
    DescribeAvailabilityZonesRequest describeAvailabilityZonesRequest = new DescribeAvailabilityZonesRequest();
    describeAvailabilityZonesRequest.setZoneNames(zoneNames);
    DescribeAvailabilityZonesResult describeAvailabilityZonesResult = ec2Operations.describeAvailabilityZones(ec2Client, describeAvailabilityZonesRequest);
    return describeAvailabilityZonesResult.getAvailabilityZones();
}

项目：cloud-runner 文件：AmazonEC2.java

public static List<String> getAllAvailabilityZones() {
    connect();

    DescribeAvailabilityZonesRequest req = new DescribeAvailabilityZonesRequest();

    ArrayList<Filter> filters = new ArrayList<Filter>();
    ArrayList<String> regions = new ArrayList<String>();
    regions.add(Configuration.REGION);
    filters.add(new Filter("region-name", regions));
    req.setFilters(filters);

    DescribeAvailabilityZonesResult res = client.describeAvailabilityZones(req);

    List<AvailabilityZone> zones = res.getAvailabilityZones();
    ArrayList<String> zonesStr = new ArrayList<String>();
    for (AvailabilityZone zone : zones)
        zonesStr.add(zone.getZoneName());

    return zonesStr;
}

项目：dohko 文件：EC2.java

private Zone getZoneByName(String zoneName)
{
    checkState(!isNullOrEmpty(zoneName));

    try
    {
        DescribeAvailabilityZonesResult zones = ec2_
                .describeAvailabilityZones(new DescribeAvailabilityZonesRequest()
                .withZoneNames(zoneName)
                .withFilters(new Filter().withName("region-name").withValues(credentials_.getRegion().getName())));

        if (zones != null && zones.getAvailabilityZones().size() == 1)
        {
            //available | impaired | unavailable
            AvailabilityZone availabilityZone = zones.getAvailabilityZones().get(0);
            return new Zone().setName(availabilityZone.getZoneName()).setRegion(credentials_.getRegion()).setStatus(availabilityZone.getState());
        }

    }
    catch (AmazonClientException exception)
    {
        LOG.debug("Invalid zone [{}]! Error message: [{}]", zoneName, exception.getMessage(), exception);
    }

    return null;
}

项目：cfnassist 文件：AutoDiscoverParams.java

private List<Parameter> fetchAutopopulateParametersFor(ProjectAndEnv projectAndEnv, List<TemplateParameter> declaredParameters, Map<String, AvailabilityZone> zones) throws IOException, InvalidStackParameterException, CannotFindVpcException {
    logger.info(String.format("Discover and populate parameters for %s and %s", templateFile.getAbsolutePath(), projectAndEnv));
    List<Parameter> matches = new LinkedList<>();
    for(TemplateParameter templateParam : declaredParameters) {
        String name = templateParam.getParameterKey();
        if (isBuiltInParamater(name))
        {
            continue;
        }
        logger.info("Checking if parameter should be auto-populated from an existing resource, param name is " + name);
        String description = templateParam.getDescription();
        if (shouldPopulateFor(description)) {
            populateParameter(projectAndEnv, matches, name, description, declaredParameters, zones);
        }
    }
    return matches;
}

项目：cfnassist 文件：AutoDiscoverParams.java

private void populateParamForZone(Collection<Parameter> results,
                                  List<TemplateParameter> declaredParameters,
                                  Map<String, AvailabilityZone> zones, String parameterName,
                                  String parameterDescription) {
    logger.info(String.format("Check parameter for zone %s and target %s", parameterName, parameterDescription));
    String target = parameterDescription.replaceFirst(PopulatesParameters.CFN_TAG_ZONE, "").toLowerCase();
    logger.debug("Check for zone " + target);
    if (zones.containsKey(target)) {
        String zoneName = zones.get(target).getZoneName();
        declaredParameters.stream().filter(declaredParameter -> declaredParameter.getParameterKey().equals(parameterName)).
                forEach(declaredParameter -> {
                    addParameterTo(results, declaredParameters, parameterName, zoneName);
                    logger.info(String.format("Adding zone parameter %s with value %s", parameterName, zoneName));
                });
    } else {
        logger.error("Could not find matching zone for target " + target);
    }
}