本文整理了Java中com.amazonaws.services.ec2.model.Filter
类的一些代码示例,展示了Filter
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Filter
类的具体详情如下:
包路径:com.amazonaws.services.ec2.model.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;
}
内容来源于网络,如有侵权,请联系作者删除!