Get Instanz-id der EC2-Instanz, die über Java

Habe ich eine AWS EC2-Instanz bereitgestellt, und ich brauche, um herauszufinden, Ihre öffentliche IP-Adresse. Howver, zu wissen, dass ich muss zuerst wissen, der Instanz-id von meinem Beispiel.

Ziel:

Ich habe einen Java-code läuft in meinem Beispiel, und ich möchte, dass code herausfinden, die aktuelle IP-oder Instanz-ID der Instanz, wo es ausgeführt wird.

Nach der Lektüre der Amazon-Dokumentation kam ich mit einer Java-Methode gibt die IP an alle Instanzen, aber das ist nicht das, was ich will, ich möchte eine Methode, die zurückgibt, wird nur die Instanz-id oder die öffentliche IP-Adresse der ausgeführten Instanz.

    /**
     * Returns a list with the public IPs of all the active instances, which are
     * returned by the {@link #getActiveInstances()} method.
     * 
     * @return  a list with the public IPs of all the active instances.
     * @see     #getActiveInstances()
     * */
    public List<String> getPublicIPs(){
        List<String> publicIpsList = new LinkedList<String>();

        //if there are no active instances, we return immediately to avoid extra 
        //computations.
        if(!areAnyActive())
            return publicIpsList;

        DescribeInstancesRequest request =  new DescribeInstancesRequest();
        request.setInstanceIds(instanceIds);

        DescribeInstancesResult result = ec2.describeInstances(request);
        List<Reservation> reservations = result.getReservations();

        List<Instance> instances;
        for(Reservation res : reservations){
            instances = res.getInstances();
            for(Instance ins : instances){
                LOG.info("PublicIP from " + ins.getImageId() + " is " + ins.getPublicIpAddress());
                publicIpsList.add(ins.getPublicIpAddress());
            }
        }

        return publicIpsList;
    }

In diesem code habe ich ein array mit den Instanz-ids aller aktiven Instanzen, aber ich weiß nicht, ob Sie "mich" oder nicht. Also gehe ich davon aus, dass mein Erster Schritt würde sein, zu wissen, wer ich bin, und dann zu Fragen für meine öffentliche IP-Adresse.

Gibt es eine änderung, die ich tun kann, um die Vorherige Methode, um mir zu geben was ich will? Gibt es einen effizienteren Weg, es zu tun?

hier die Lösung: codeflex.co/java-get-ec2-private-public-ip-und-instance-id

InformationsquelleAutor Flame_Phoenix | 2014-04-15

amazon-ec2 amazon-web-services ip java

2

~~ich bin kein java-Typ. Aber, meine unten, ruby-code druckt das Instance ID und Public IP des running - Instanzen, wie Sie gebraucht:~~

ec2.describe_instances( filters:[ { name: "instance-state-name", values: ["running"] } ] ).each do |resp| resp.reservations.each do |reservation| reservation.instances.each do |instance| puts instance.instance_id + " ---AND--- " + instance.public_ip_address end end end

Alles, was Sie tun müssen, ist finden sich entsprechende Methoden/Aufrufe im JAVA-SDK-Dokumentation. Der code, den Sie betrachten sollten ist:

filters:[ { name: "instance-state-name", values: ["running"] }

In den oben block, ich bin herausfiltern nur die läuft Instanzen.

UND

resp.reservations.each do |reservation| reservation.instances.each do |instance| puts instance.instance_id + " ---AND--- " + instance.public_ip_address

Im obigen code-block, den ich bin mit 2 for Schleifen und ziehen instance.instance_id sowie instance.public_ip_address.

Als JAVA-SDK und Ruby-SDK sind beide schlagen die AWS EC2-APIs, muss es ähnliche Einstellungen im JAVA-SDK.

Auch Deine Frage ist so vage in dem Sinne, sind Sie die Ausführung des JAVA-Codes von der Instanz, deren Instanz-id wird benötigt? ODER Sind Sie die Ausführung von java-code aus einer anderen Instanz und möchten, ziehen Sie den Instanz-ids aller Laufenden Instanzen?

UPDATE:

Aktualisierung der Antworten, die Frage hat sich geändert:

AWS bietet meta-Daten-service auf jede Instanz, die gestartet wird. Sie können eine Umfrage der meta-Daten-service lokal zu finden, aus der die benötigten Informationen.

Form bash promp, unten bereitgestellten Befehl die Instanz-id und die öffentliche IP-Adresse der Instanz
```
$ curl -L http://169.254.169.254/latest/meta-data/instance-id

$ curl -L http://169.254.169.254/latest/meta-data/public-ipv4
```
Müssen Sie herausfinden, wie Sie ziehen die Daten aus oben genannten URLs in java. An diesem Punkt , Sie haben genügend Informationen, und diese Frage ist irrelevant im Hinblick auf AWS-weil das ist jetzt mehr eine JAVA Frage auf, wie man Umfrage über URLs.
- Code gibt mir die IPs und IDs der all meine Laufenden Instanzen, so ist es nicht genau das, was mein code tut. Das ist nicht was ich will aber was ich will, ist die Öffentliche IP-oder Instanz-ID von meinem Beispiel, so kann ich es identifizieren.
- Ich bearbeitet meine Frage so klar wie möglich. Ich hoffe, dass alle Arten der Unbestimmtheit sind nun Weg !
- das update angezeigt.
- Also, du bist mir zu sagen, dass das Java-SDK nicht unterstützt dieses feature nativ, und dass ich gezwungen bin, eine Umfrage-URL, die Antwort zu finden? Ich finde das komisch ...
- Falsch, es ist nicht ein JAVA-SDK Nachteil, in der Tat, AWS EC2-APIs nicht über eine solche Funktion. Es können nur gezogen werden mit Hilfe der meta-Daten-service wie oben erwähnt, und ich finde nichts seltsames dran.
- Also, auch wenn Sie ein Ruby-fan, oder PHP-fan, oder irgendetwas anderes, das ist der Weg zu gehen, richtig? Gut, ich hatte keine Ahnung. ein dickes Lob++ Sir, thx für deine Zeit.
- Das ist richtig. Als die APIs selbst diese Funktion nicht haben, keiner der SDKs kann das tun. Meta-Daten-service ist der einzige Ausweg.
- tl;dr diese url wird für die Instanz-id: "169.254.169.254/latest/meta-data/instance-id
- Diese Antwort nutzt curl, aber die Frage fragt nach der Verwendung von Java.
InformationsquelleAutor slayedbylucifer

Ich würde vorschlagen/empfehlen die Verwendung von AWS SDK für Java.

//Resolve the instanceId
String instanceId = EC2MetadataUtils.getInstanceId();

//Resolve (first/primary) private IP
String privateAddress = EC2MetadataUtils.getInstanceInfo().getPrivateIp();

//Resolve public IP
AmazonEC2 client = AmazonEC2ClientBuilder.defaultClient();
String publicAddress = client.describeInstances(new DescribeInstancesRequest()
                                                    .withInstanceIds(instanceId))
                             .getReservations()
                             .stream()
                             .map(Reservation::getInstances)
                             .flatMap(List::stream)
                             .findFirst()
                             .map(Instance::getPublicIpAddress)
                             .orElse(null);

Es sei denn Java8 ist verfügbar, diese müssen mehr boilercode. Aber in der nussschale, das ist es.

https://stackoverflow.com/a/30317951/525238 schon erwähnt hat die EC2MetadataUtils, aber diese hier umfasst die Zusammenarbeit code auch.

Danke. Perfekte Antwort.
hoffe, dass dies für Sie gearbeitet, aber ich erhalte eine Fehlermeldung in AmazonEC2ClientBuilder.defaultClient () - Anweisung . sagen keine solche Methode zur Verfügung
Vielleicht hat Sie sich geändert haben die api seit 2015 -- das sind vor 3 Jahren. Auch zu beachten, für späteres nachschlagen: Dies ist alles über AWS Java SDK v1.

InformationsquelleAutor knalli

24

Du willst die com.amazonaws.util.EC2MetadataUtils Klasse von der aws-java-sdk.
- Dies sollte die richtige Antwort.
InformationsquelleAutor heldeen

Folgende Methode zurück, die EC2-Instance-ID.

public String retrieveInstanceId() throws IOException {
    String EC2Id = null;
    String inputLine;
    URL EC2MetaData = new URL("http://169.254.169.254/latest/meta-data/instance-id");
    URLConnection EC2MD = EC2MetaData.openConnection();
    BufferedReader in = new BufferedReader(new InputStreamReader(EC2MD.getInputStream()));
    while ((inputLine = in.readLine()) != null) {
        EC2Id = inputLine;
    }
    in.close();
    return EC2Id;
}

Von hier aus können Sie dann Folgendes tun, um Informationen wie die IP-Adresse (in diesem Beispiel die privateIP):

try {
    myEC2Id = retrieveInstanceId();
} catch (IOException e1) {
    e1.printStackTrace(getErrorStream());
}
DescribeInstancesRequest describeInstanceRequest = new DescribeInstancesRequest().withInstanceIds(myEC2Id);
DescribeInstancesResult describeInstanceResult = ec2.describeInstances(describeInstanceRequest);
System.out.println(describeInstanceResult.getReservations().get(0).getInstances().get(0).getPrivateIPAddress());

Können Sie diese auch verwenden, um alle Arten von relevanten Informationen über die aktuelle Instanz der Java-Programm ausgeführt wird; ersetzen Sie einfach .getPrivateIPAddress() mit den entsprechenden get-Befehl für die info, die Sie suchen. Liste der verfügbaren Befehle finden hier.

Edit: Für diejenigen, die sich vielleicht scheuen, mit diesem, aufgrund der "unbekannten" URL; siehe Amazon ' s Dokumentation zu dem Thema, die Punkte direkt auf die gleiche URL; nur mit dem Unterschied, Sie tun es über cli-eher als in Java. http://docs.aws.amazon.com/AWSEC2/latest/UserGuide/ec2-instance-metadata.html

InformationsquelleAutor DGolberg

3

Antwort auf die erste Frage von

Habe ich eine AWS EC2-Instanz bereitgestellt, und ich brauche, um herauszufinden, Ihre öffentliche IP-Adresse.

Kann man in Java über die AWS-API:
```
EC2MetadataUtils.getData("/latest/meta-data/public-ipv4");
```
Diese wird direkt geben Sie die öffentliche IP-falls vorhanden

InformationsquelleAutor Max Dor
1

Hier könnte die Metadaten-Dienst zu Holen, diese mit HTTP:
http://docs.aws.amazon.com/AWSEC2/latest/UserGuide/AESDG-chapter-instancedata.html

ex:
```
GET http://169.254.169.254/latest/meta-data/instance-id
```
- Nicht das Java SDK verwendet wird, ist es nicht die Lösung, die ich Suche, und es löst keines der Probleme, die ich bin mit. Sry.
- Es scheint, war Ihre Antwort richtig, nachdem alle. Dies ist der einzige Weg, um dieses problem anzugehen, wie die AWS EC2 API unterstützt diese Funktion nicht in irgendeiner anderen Weise. ein dickes Lob++ Sir.
InformationsquelleAutor faermanj

War ich, dass zu viele Operationen mit Amazon EC2. Dann habe ich implementiert eine utility-Klasse für diese Operationen. Vielleicht kann es sein, util, um jemanden, der hier ankommen. Ich, implementiert unter Verwendung von AWS SDK für java-version 2. Die Operationen sind:

Erstellen Maschine;
Start der Maschine;
Stoppen der Maschine;
Neustart der Maschine;
Maschine löschen (Terminate);
Beschreiben-Maschine;
Get Public IP von der Maschine;

AmazonEC2 Klasse:

import govbr.cloud.management.api.CloudManagementException;
import govbr.cloud.management.api.CloudServerMachine;
import software.amazon.awssdk.auth.credentials.AwsCredentialsProvider;
import software.amazon.awssdk.core.exception.SdkClientException;
import software.amazon.awssdk.core.exception.SdkServiceException;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.ec2.Ec2Client;
import software.amazon.awssdk.services.ec2.model.DescribeInstancesRequest;
import software.amazon.awssdk.services.ec2.model.DescribeInstancesResponse;
import software.amazon.awssdk.services.ec2.model.Ec2Exception;
import software.amazon.awssdk.services.ec2.model.Instance;
import software.amazon.awssdk.services.ec2.model.InstanceNetworkInterface;
import software.amazon.awssdk.services.ec2.model.InstanceType;
import software.amazon.awssdk.services.ec2.model.RebootInstancesRequest;
import software.amazon.awssdk.services.ec2.model.Reservation;
import software.amazon.awssdk.services.ec2.model.RunInstancesRequest;
import software.amazon.awssdk.services.ec2.model.RunInstancesResponse;
import software.amazon.awssdk.services.ec2.model.StartInstancesRequest;
import software.amazon.awssdk.services.ec2.model.StopInstancesRequest;
import software.amazon.awssdk.services.ec2.model.TerminateInstancesRequest;


public class AmazonEC2 {

    private final static String EC2_MESSAGE_ERROR = "A error occurred on the     Ec2.";
    private final static String CLIENT_MESSAGE_ERROR = "A error occurred in client side.";
    private final static String SERVER_MESSAGE_ERROR = "A error occurred in Amazon server.";
    private final static String UNEXPECTED_MESSAGE_ERROR = "Unexpected error occurred.";


    private Ec2Client buildDefaultEc2() {

        AwsCredentialsProvider credentials = AmazonCredentials.loadCredentialsFromFile();

        Ec2Client ec2 = Ec2Client.builder()
                .region(Region.SA_EAST_1)
                .credentialsProvider(credentials)                            
                .build();

        return ec2;
    }

    public String createMachine(String name, String amazonMachineId) 
                        throws CloudManagementException {
        try {
            if(amazonMachineId == null) {
                amazonMachineId = "ami-07b14488da8ea02a0";              
            }       

            Ec2Client ec2 = buildDefaultEc2();           

            RunInstancesRequest request = RunInstancesRequest.builder()
                    .imageId(amazonMachineId)
                    .instanceType(InstanceType.T1_MICRO)
                    .maxCount(1)
                    .minCount(1)
                    .build();

            RunInstancesResponse response = ec2.runInstances(request);

            Instance instance = null;

            if (response.reservation().instances().size() > 0) {
                instance = response.reservation().instances().get(0);
            }

            if(instance != null) {
                System.out.println("Machine created! Machine identifier: " 
                                    + instance.instanceId());
                return instance.instanceId();
            }

            return null;

        } catch (Ec2Exception e) {          
            throw new CloudManagementException(EC2_MESSAGE_ERROR, e);   
        } catch (SdkClientException e) {
            throw new CloudManagementException(CLIENT_MESSAGE_ERROR, e);            
        } catch (SdkServiceException e) {
            throw new CloudManagementException(SERVER_MESSAGE_ERROR, e);            
        } catch (Exception e) {
            throw new CloudManagementException(UNEXPECTED_MESSAGE_ERROR, e);            
        }       
    }

    public void startMachine(String instanceId) {
        try {

            Ec2Client ec2 = buildDefaultEc2();
            StartInstancesRequest request = StartInstancesRequest.builder()
                                             .instanceIds(instanceId).build();
            ec2.startInstances(request);

        } catch (Ec2Exception e) {          
            throw new CloudManagementException(EC2_MESSAGE_ERROR, e);   
        } catch (SdkClientException e) {
            throw new CloudManagementException(CLIENT_MESSAGE_ERROR, e);            
        } catch (SdkServiceException e) {
            throw new CloudManagementException(SERVER_MESSAGE_ERROR, e);            
        } catch (Exception e) {
            throw new CloudManagementException(UNEXPECTED_MESSAGE_ERROR, e);            
        }   
    }

    public void stopMachine(String instanceId) {
        try {

            Ec2Client ec2 = buildDefaultEc2();
            StopInstancesRequest request = StopInstancesRequest.builder()
                                              .instanceIds(instanceId).build();
            ec2.stopInstances(request);

        } catch (Ec2Exception e) {          
            throw new CloudManagementException(EC2_MESSAGE_ERROR, e);   
        } catch (SdkClientException e) {
            throw new CloudManagementException(CLIENT_MESSAGE_ERROR, e);            
        } catch (SdkServiceException e) {
            throw new CloudManagementException(SERVER_MESSAGE_ERROR, e);            
        } catch (Exception e) {
            throw new CloudManagementException(UNEXPECTED_MESSAGE_ERROR, e);            
        }   
    }

    public void rebootMachine(String instanceId) {
        try {

            Ec2Client ec2 = buildDefaultEc2();
            RebootInstancesRequest request = RebootInstancesRequest.builder()
                                              .instanceIds(instanceId).build();
            ec2.rebootInstances(request);

        } catch (Ec2Exception e) {          
            throw new CloudManagementException(EC2_MESSAGE_ERROR, e);   
        } catch (SdkClientException e) {
            throw new CloudManagementException(CLIENT_MESSAGE_ERROR, e);            
        } catch (SdkServiceException e) {
            throw new CloudManagementException(SERVER_MESSAGE_ERROR, e);            
        } catch (Exception e) {
            throw new CloudManagementException(UNEXPECTED_MESSAGE_ERROR, e);            
        }   
    }

    public void destroyMachine(String instanceId) {
        try {

            Ec2Client ec2 = buildDefaultEc2();
            TerminateInstancesRequest request = TerminateInstancesRequest.builder()
       .instanceIds(instanceId).build();
            ec2.terminateInstances(request);

        } catch (Ec2Exception e) {          
            throw new CloudManagementException(EC2_MESSAGE_ERROR, e);   
        } catch (SdkClientException e) {
            throw new CloudManagementException(CLIENT_MESSAGE_ERROR, e);            
        } catch (SdkServiceException e) {
            throw new CloudManagementException(SERVER_MESSAGE_ERROR, e);            
        } catch (Exception e) {
            throw new CloudManagementException(UNEXPECTED_MESSAGE_ERROR, e);            
        }   
    }

    public String getPublicIpAddress(String instanceId) throws CloudManagementException {
        try {

            Ec2Client ec2 = buildDefaultEc2();

            boolean done = false;

            DescribeInstancesRequest request = DescribeInstancesRequest.builder().build();

            while(!done) {
                DescribeInstancesResponse response = ec2.describeInstances(request);

                for(Reservation reservation : response.reservations()) {
                    for(Instance instance : reservation.instances()) {
                        if(instance.instanceId().equals(instanceId)) {
                            if(instance.networkInterfaces().size() > 0) {
                                InstanceNetworkInterface networkInterface = 
                                           instance.networkInterfaces().get(0);
                                String publicIp = networkInterface
                                                     .association().publicIp();
                                System.out.println("Machine found. Machine with Id " 
                                                   + instanceId 
                                                   + " has the follow public IP: " 
                                                   + publicIp);
                                return publicIp;
                            }                           
                        }
                    }
                }

                if(response.nextToken() == null) {
                    done = true;
                }
            }

            return null;

        } catch (Ec2Exception e) {          
            throw new CloudManagementException(EC2_MESSAGE_ERROR, e);   
        } catch (SdkClientException e) {
            throw new CloudManagementException(CLIENT_MESSAGE_ERROR, e);            
        } catch (SdkServiceException e) {
            throw new CloudManagementException(SERVER_MESSAGE_ERROR, e);            
        } catch (Exception e) {
            throw new CloudManagementException(UNEXPECTED_MESSAGE_ERROR, e);            
        }   
    }

    public String describeMachine(String instanceId) {
        try {

            Ec2Client ec2 = buildDefaultEc2();          

            boolean done = false;

            DescribeInstancesRequest request = DescribeInstancesRequest.builder().build();

            while(!done) {
                DescribeInstancesResponse response = ec2.describeInstances(request);

                for(Reservation reservation : response.reservations()) {
                    for(Instance instance : reservation.instances()) {
                        if(instance.instanceId().equals(instanceId)) {                          
                            return "Found reservation with id " +
                                    instance.instanceId() +
                                    ", AMI " + instance.imageId() + 
                                    ", type " + instance.instanceType() + 
                                    ", state " + instance.state().name() + 
                                    "and monitoring state" + 
                                    instance.monitoring().state();                          
                        }
                    }
                }

                if(response.nextToken() == null) {
                    done = true;
                }
            }

            return null;

        } catch (Ec2Exception e) {          
            throw new CloudManagementException(EC2_MESSAGE_ERROR, e);   
        } catch (SdkClientException e) {
            throw new CloudManagementException(CLIENT_MESSAGE_ERROR, e);            
        } catch (SdkServiceException e) {
            throw new CloudManagementException(SERVER_MESSAGE_ERROR, e);            
        } catch (Exception e) {
            throw new CloudManagementException(UNEXPECTED_MESSAGE_ERROR, e);            
        }   
    }

}

AmazonCredentials Klasse:

import java.io.InputStream;

import software.amazon.awssdk.auth.credentials.AwsCredentialsProvider;
import software.amazon.awssdk.auth.credentials.ProfileCredentialsProvider;
import software.amazon.awssdk.profiles.ProfileFile;
import software.amazon.awssdk.profiles.ProfileFile.Type;

public class AmazonCredentials {


public static AwsCredentialsProvider loadCredentialsFromFile() {
    InputStream profileInput = ClassLoader.getSystemResourceAsStream("credentials.profiles");

    ProfileFile profileFile = ProfileFile.builder()
            .content(profileInput)
            .type(Type.CREDENTIALS)
            .build();

    AwsCredentialsProvider profileProvider = ProfileCredentialsProvider.builder()
            .profileFile(profileFile)
            .build();

    return profileProvider;
}

}

CloudManagementException Klasse:

public class CloudManagementException extends RuntimeException {

private static final long serialVersionUID = 1L;


public CloudManagementException(String message) {
    super(message);
}

public CloudManagementException(String message, Throwable cause) {
    super(message, cause);
}

}

Anmeldeinformationen.profile:

[default]
aws_access_key_id={your access key id here}
aws_secret_access_key={your secret access key here}

Ich hoffe, helfen, o/

InformationsquelleAutor Filipe Luchini

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.