com.amazonaws.services.ec2.model.Filter类的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(10.7k)|赞(0)|评价(0)|浏览(125)

本文整理了Java中com.amazonaws.services.ec2.model.Filter类的一些代码示例,展示了Filter类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Filter类的具体详情如下:
包路径:com.amazonaws.services.ec2.model.Filter
类名称:Filter

Filter介绍

[英]A filter name and value pair that is used to return a more specific list of results from a describe operation. Filters can be used to match a set of resources by specific criteria, such as tags, attributes, or IDs. The filters supported by a describe operation are documented with the describe operation. For example:

代码示例

代码示例来源:origin: apache/incubator-gobblin

/***
 * Get list of EC2 {@link Instance}s for a auto scaling group
 *
 * @param groupName Auto scaling group name
 * @param status Instance status (eg. running)
 * @return List of EC2 instances found for the input auto scaling group
 */
public List<Instance> getInstancesForGroup(String groupName,
  String status) {
 final AmazonEC2 amazonEC2 = getEc2Client();
 final DescribeInstancesResult instancesResult = amazonEC2.describeInstances(new DescribeInstancesRequest()
   .withFilters(new Filter().withName("tag:aws:autoscaling:groupName").withValues(groupName)));
 final List<Instance> instances = new ArrayList<>();
 for (Reservation reservation : instancesResult.getReservations()) {
  for (Instance instance : reservation.getInstances()) {
   if (null == status|| null == instance.getState()
     || status.equals(instance.getState().getName())) {
    instances.add(instance);
    LOGGER.info("Found instance: " + instance + " which qualified filter: " + status);
   } else {
    LOGGER.info("Found instance: " + instance + " but did not qualify for filter: " + status);
   }
  }
 }
 return instances;
}

代码示例来源:origin: aws/aws-sdk-java

/**
 * <p>
 * One or more filter values. Filter values are case-sensitive.
 * </p>
 * <p>
 * <b>NOTE:</b> This method appends the values to the existing list (if any). Use
 * {@link #setValues(java.util.Collection)} or {@link #withValues(java.util.Collection)} if you want to override the
 * existing values.
 * </p>
 * 
 * @param values
 *        One or more filter values. Filter values are case-sensitive.
 * @return Returns a reference to this object so that method calls can be chained together.
 */
public Filter withValues(String... values) {
  if (this.values == null) {
    setValues(new com.amazonaws.internal.SdkInternalList<String>(values.length));
  }
  for (String ele : values) {
    this.values.add(ele);
  }
  return this;
}

代码示例来源:origin: aws/aws-sdk-java

/**
 * Constructs a new Filter object. Callers should use the setter or fluent setter (with...) methods to initialize
 * any additional object members.
 * 
 * @param name
 *        The name of the filter. Filter names are case-sensitive.
 * @param values
 *        One or more filter values. Filter values are case-sensitive.
 */
public Filter(String name, java.util.List<String> values) {
  setName(name);
  setValues(values);
}

代码示例来源:origin: Netflix/Priam

protected String getVpcGoupId() {
  AmazonEC2 client = null;
  try {
    client = getEc2Client();
    Filter nameFilter =
        new Filter().withName("group-name").withValues(config.getACLGroupName()); // SG
    Filter vpcFilter = new Filter().withName("vpc-id").withValues(instanceInfo.getVpcId());
    DescribeSecurityGroupsRequest req =
        new DescribeSecurityGroupsRequest().withFilters(nameFilter, vpcFilter);
    DescribeSecurityGroupsResult result = client.describeSecurityGroups(req);
    for (SecurityGroup group : result.getSecurityGroups()) {
      logger.debug(
          "got group-id:{} for group-name:{},vpc-id:{}",
          group.getGroupId(),
          config.getACLGroupName(),
          instanceInfo.getVpcId());
      return group.getGroupId();
    }
    logger.error(
        "unable to get group-id for group-name={} vpc-id={}",
        config.getACLGroupName(),
        instanceInfo.getVpcId());
    return "";
  } finally {
    if (client != null) client.shutdown();
  }
}

代码示例来源:origin: apache/incubator-druid

new DescribeInstancesRequest()
  .withFilters(
    new Filter("private-ip-address", ips)

代码示例来源:origin: apache/incubator-druid

new DescribeInstancesRequest().withFilters(new Filter("private-ip-address", input))
).getReservations();

代码示例来源:origin: Netflix/eureka

.withFilters(new Filter("private-ip-address", ips))
        .withFilters(new Filter("status", Lists.newArrayList("available")))
        .withFilters(new Filter("subnet-id", Lists.newArrayList(subnetId)))
);

代码示例来源:origin: electronicarts/gatling-aws-maven-plugin

private Filter[] getInstanceFilters(final String instanceType) {
  // Setup a filter to find any previously generated EC2 instances.
  return new Filter[]{
    new Filter("tag:" + this.instanceTag.getKey()).withValues(this.instanceTag.getValue()),
    new Filter("instance-state-name").withValues("running"),
    new Filter("instance-type").withValues(instanceType)
  };
}

代码示例来源:origin: org.jenkins-ci.plugins/ec2

diFilters.add(new Filter("image-id").withValues(ami));
  diFilters.add(new Filter("availability-zone").withValues(getZone()));
  diFilters.add(new Filter("subnet-id").withValues(getSubnetId()));
      diFilters.add(new Filter("instance.group-id").withValues(group_ids));
    diFilters.add(new Filter("instance.group-name").withValues(securityGroupSet));
riRequest.setUserData(userDataString);
riRequest.setKeyName(keyPair.getKeyName());
diFilters.add(new Filter("key-name").withValues(keyPair.getKeyName()));
riRequest.setInstanceType(type.toString());
diFilters.add(new Filter("instance-type").withValues(type.toString()));
  for(EC2Tag t : tags) {
    inst_tags.add(new Tag(t.getName(), t.getValue()));
    diFilters.add(new Filter("tag:"+t.getName()).withValues(t.getValue()));
    if (StringUtils.equals(t.getName(), EC2Tag.TAG_NAME_JENKINS_SLAVE_TYPE)) {
      hasCustomTypeTag = true;
DescribeInstancesRequest diRequest = new DescribeInstancesRequest();
diFilters.add(new Filter("instance-state-name").withValues(InstanceStateName.Stopped.toString(),
    InstanceStateName.Stopping.toString()));
diRequest.setFilters(diFilters);

代码示例来源:origin: pinterest/soundwave

try {
 List<Instance> ret = new ArrayList<>();
 DescribeInstancesRequest request = new DescribeInstancesRequest()
   .withMaxResults(1000)
   .withFilters(new Filter("availability-zone", Arrays.asList(zone.getZoneName())))
   .withSdkClientExecutionTimeout(
     600 * 1000) //10 minutes time out for total execution including retries

代码示例来源:origin: com.netflix.spinnaker.clouddriver/clouddriver-aws

DescribeInstancesRequest describeInstances = new DescribeInstancesRequest().withMaxResults(500);
while (true) {
 DescribeInstancesResult instanceResult = ec2.describeInstances(describeInstances);
  break;
 describeInstances.setNextToken(instanceResult.getNextToken());
 new DescribeSecurityGroupsRequest()
  .withFilters(
   new Filter("vpc-id").withValues(classicLinkVpcId)))
 .getSecurityGroups()
 .stream()

代码示例来源:origin: aws/aws-sdk-java

public Filter unmarshall(StaxUnmarshallerContext context) throws Exception {
  Filter filter = new Filter();
  int originalDepth = context.getCurrentDepth();
  int targetDepth = originalDepth + 1;
  if (context.isStartOfDocument())
    targetDepth += 1;
  while (true) {
    XMLEvent xmlEvent = context.nextEvent();
    if (xmlEvent.isEndDocument())
      return filter;
    if (xmlEvent.isAttribute() || xmlEvent.isStartElement()) {
      if (context.testExpression("Name", targetDepth)) {
        filter.setName(StringStaxUnmarshaller.getInstance().unmarshall(context));
        continue;
      }
      if (context.testExpression("Value", targetDepth)) {
        filter.withValues(new ArrayList<String>());
        continue;
      }
      if (context.testExpression("Value/item", targetDepth)) {
        filter.withValues(StringStaxUnmarshaller.getInstance().unmarshall(context));
        continue;
      }
    } else if (xmlEvent.isEndElement()) {
      if (context.getCurrentDepth() < originalDepth) {
        return filter;
      }
    }
  }
}

代码示例来源:origin: tmobile/pacbot

public static Filter setFilters(String filterName, String filterValue) {
  Filter filter = new Filter();
  filter.setName(filterName);
  filter.setValues(Arrays.asList(filterValue));
  return filter;
}

代码示例来源:origin: tmobile/pacbot

/**
 *
 * @param resourceId
 * @param clientMap
 * @return
 */
private String getEC2PacManTagValue(String resourceId, Map<String, Object> clientMap) {
  AmazonEC2 ec2Client = (AmazonEC2) clientMap.get("client");
  DescribeTagsRequest describeTagsRequest = new DescribeTagsRequest();
  Filter filter = new Filter("resource-id");
  filter.setValues(Arrays.asList(resourceId));
  describeTagsRequest.setFilters(Arrays.asList(filter));
  DescribeTagsResult describeTagsResult = ec2Client.describeTags(describeTagsRequest);
  List<TagDescription> descriptions = describeTagsResult.getTags();
  TagDescription tagDescription = null;
  Optional<TagDescription> optional = descriptions.stream()
      .filter(obj -> obj.getKey().equals(PacmanSdkConstants.PACMAN_AUTO_FIX_TAG_NAME)).findAny();
  if (optional.isPresent()) {
    tagDescription = optional.get();
  } else {
    return null;
  }
  return tagDescription.getValue();
}
/**

代码示例来源:origin: aws-amplify/aws-sdk-android

/**
 * One or more filter values. Filter values are case-sensitive.
 * <p>
 * Returns a reference to this object so that method calls can be chained together.
 *
 * @param values One or more filter values. Filter values are case-sensitive.
 *
 * @return A reference to this updated object so that method calls can be chained
 *         together.
 */
public Filter withValues(String... values) {
  if (getValues() == null) setValues(new java.util.ArrayList<String>(values.length));
  for (String value : values) {
    getValues().add(value);
  }
  return this;
}

代码示例来源:origin: aws/aws-sdk-java

/**
 * <p>
 * One or more filter values. Filter values are case-sensitive.
 * </p>
 * 
 * @param values
 *        One or more filter values. Filter values are case-sensitive.
 * @return Returns a reference to this object so that method calls can be chained together.
 */
public Filter withValues(java.util.Collection<String> values) {
  setValues(values);
  return this;
}

代码示例来源:origin: apache/usergrid

new LinkedList<com.amazonaws.services.ec2.model.Instance>();
DescribeInstancesRequest request = new DescribeInstancesRequest();
  Filter filter = new Filter("tag:Name", valuesT1);
  request = request.withFilters( filter );
  Filter filter = new Filter( "instance-state-name", valuesT1 );
  request = request.withFilters( filter );

代码示例来源:origin: apache/incubator-druid

new DescribeInstancesRequest().withFilters(new Filter("instance-id", input))
).getReservations();

代码示例来源:origin: Netflix/Priam

new Filter().withName("group-name").withValues(config.getACLGroupName());
String vpcid = instanceInfo.getVpcId();
if (vpcid == null || vpcid.isEmpty()) {
Filter vpcFilter = new Filter().withName("vpc-id").withValues(vpcid);
DescribeSecurityGroupsRequest req =
    new DescribeSecurityGroupsRequest().withFilters(nameFilter, vpcFilter);

代码示例来源:origin: stackoverflow.com

/**
* create new contact filter for ALL LIGHTS with give parameters
*/
static public void setContactFilter(short categoryBits, short groupIndex,
      short maskBits) {
  filterA = new Filter();
  filterA.categoryBits = categoryBits;
  filterA.groupIndex = groupIndex;
  filterA.maskBits = maskBits;
}

相关文章