Hi Tom,
Thanks for replying...
Im using VC 2.5.0 build 84767
I am trying to collect Disk performance of Host and VM.....
I want to collect three counters values : 1) read 2) write 3)numberRead
Following is the code for collecting Disk Read metrics data of Virtual Machine....
public class DiskRead {
public BufferedWriter output;
int interval = 10,maxSample=10,intervalID=20;
File file;
FileWriter fw;
public int getIntervalID()
{
return this.intervalID;
}
public int getMaxSample()
{
return this.maxSample;
}
public int getInterval()
{
return this.interval;
}
public void setInterval(int i)
{
interval = i;
}
public void setMaxSample(int i)
{
maxSample = i;
}
public void setIntervalID(int i)
{
intervalID = i;
}
private static AppUtil cb = null;
private void doRealTime() throws Exception {
ManagedObjectReference vmmor = cb.getServiceUtil().getDecendentMoRef(
null, "VirtualMachine", cb.get_option("vmname"));
if (vmmor != null) {
ManagedObjectReference pmRef =
cb.getConnection().getServiceContent().getPerfManager();
PerfCounterInfo[] cInfo =
(PerfCounterInfo[]) cb.getServiceUtil().getDynamicProperty(pmRef, "perfCounter");
List vmDiskReadCounters = new ArrayList();
for (int i = 0; i < cInfo.length; ++i) {
/* if("disk".equalsIgnoreCase(cInfo[i].getGroupInfo().getKey()))
{
System.out.println(cInfo[i].getNameInfo().getLabel());
} */
if ("disk read rate".equalsIgnoreCase(cInfo[i].getNameInfo().getLabel())) {
vmDiskReadCounters.add(cInfo[i]);
}
}
Map DiskReadCounters = new HashMap();
while (true) {
int index = 0;
for (Iterator it = vmDiskReadCounters.iterator(); it.hasNext();) {
PerfCounterInfo pcInfo = (PerfCounterInfo) it.next();
System.out.println(++index + " - "
+ pcInfo.getNameInfo().getSummary());
}
/*index = cb.getUtil().getIntInput(
"Please select a counter from" + " the above list"
+ "\nEnter 0 to end: ", 1);*/
index = 1;
if (index > vmDiskReadCounters.size()) {
System.out.println("*** Value out of range!");
} else {
--index;
if (index < 0)
return;
PerfCounterInfo pcmemoryInfo = (PerfCounterInfo) vmDiskReadCounters
.get(index);
DiskReadCounters.put(new Integer(pcmemoryInfo.getKey()), pcmemoryInfo);
break;
}
}
PerfMetricId[] aMetrics = cb.getConnection().getService()
.queryAvailablePerfMetric(pmRef, vmmor, null, null,
new Integer(20));
ArrayList memorymMetrics = new ArrayList();
if (aMetrics != null) {
for (int index = 0; index < aMetrics.length; ++index) {
if (DiskReadCounters.containsKey(new Integer(aMetrics[index].getCounterId()))) {
memorymMetrics.add(aMetrics[index]);
}
}
}
monitorPerformance(pmRef, vmmor, memorymMetrics, DiskReadCounters);
} else {
System.out.println("Virtual Machine " + cb.get_option("vmname")
+ " not found");
}
}
void monitorPerformance(ManagedObjectReference pmRef,
ManagedObjectReference vmRef, ArrayList mMetrics, Map counters)
throws Exception {
PerfMetricId[] metricIds = (PerfMetricId[]) mMetrics
.toArray(new PerfMetricId[0]);
PerfQuerySpec qSpec = new PerfQuerySpec();
qSpec.setEntity(vmRef);
qSpec.setMaxSample(new Integer(maxSample));
qSpec.setMetricId(metricIds);
qSpec.setIntervalId(new Integer(intervalID));
PerfQuerySpec[] qSpecs = new PerfQuerySpec[] { qSpec };
while (true) {
PerfEntityMetricBase[] pValues = cb.getConnection().getService()
.queryPerf(pmRef, qSpecs);
if (pValues != null)
displayValues(pValues, counters);
System.out.println("Sleeping "+interval+" seconds...");
Thread.sleep(interval * 1000);
}
}
void displayValues(PerfEntityMetricBase[] values, Map counters) {
for (int i = 0; i < values.length; ++i) {
PerfMetricSeries[] vals = ((PerfEntityMetric) values[i]).getValue();
PerfSampleInfo[] infos = ((PerfEntityMetric) values[i])
.getSampleInfo();
String time[] = new String[2];
time[0] = infos[0].getTimestamp().getTime().toString();
time[1] = infos[http://infos.length -1|http://infos.length -1].getTimestamp().getTime().toString();
System.out.println("Sample Time Range: "
+ time[0] + " -- " + time[1] );
for (int vi = 0; vi < vals.length; ++vi)
{
PerfCounterInfo pci = (PerfCounterInfo) counters
.get(new Integer(vals[vi].getId().getCounterId()));
/*if (pci != null)
System.out.println(pci.getNameInfo().getSummary());
*/
if (vals[vi] instanceof PerfMetricIntSeries) {
try
{
PerfMetricIntSeries val = (PerfMetricIntSeries) vals[vi];
long[] longs = val.getValue();
output.append(time[0]);
for (int k = 0; k < getMaxSample(); ++k) {
output.append("," + longs[k]);
System.out.print(" " + longs[k] + " ");
}
output.newLine();
output.flush();
System.out.println();
}catch(Exception e){}
}
}
}
}
private static OptionSpec[] constructOptions() {
OptionSpec[] useroptions = new OptionSpec[1];
useroptions[0] = new OptionSpec("vmname", "String", 1,
"Name of the virtual machine", null);
return useroptions;
}
public static void main(String[] args) throws Exception {
// run.bat com.vmware.samples.performance.Realtime --url
// --username --password
// --vmname
args = new String[9];
args[0] = "--url";
args[1] = "[https://192.168.0.27/sdk]"; //VC sdk
args[2] = "--username";
args[3] = "191513";
args[4] = "--password";
args[5] = "[mailto:p@ssw0rd_jul]";
args[6] = "--vmname";
args[7] = "Windows2003";
// args[7] = "UbuntuVMesx1";
args[8] = "--ignorecert";
DiskRead obj = new DiskRead();
obj.setInterval(10); //time after which the data to be collected
obj.setIntervalID(20); // refresh rate of data (must be 20sec)
obj.setMaxSample(1); //number of samples to be collected within sampling period (setInterval)
obj.file = new File("C:
VMwareDynamicData
Disk
DiskRead.csv"); //Data will be stored in this file
obj.fw = new FileWriter(obj.file);
obj.output = new BufferedWriter(new FileWriter(obj.file));
obj.output.append("Time," +args[7] + "");
obj.output.newLine();
obj.output.flush();
cb = AppUtil.initialize("RealTime", DiskRead.constructOptions(), args);
cb.connect();
obj.doRealTime();
cb.disConnect();
}
}
