ec2 인스턴스의 사용자 데이터에서 xml 행을 편집하려면 어떻게해야합니까?

Question

백엔드에서 스핀 업되는 여러 ec2 인스턴스에서 Wowza 스트리밍 엔진을 사용하고 있습니다. 원점과 가장자리 인스턴스를 연결하는 방법이 필요하며 XML 파일의 특정 라인 값을 업데이트해야합니다. 나는 가장자리가 회전 할 때까지 IP를 사용자 데이터에로드했습니다. 이 태그의 값을 사용자 데이터에서 편집하는 스크립트를 시작하려면 무엇이 필요합니까?

Answer 1

가정하면 origin_ip 정의된다 :

script = "#!/bin/bash 
      sed -i -e '/<Name>loadbalanceServerIP<\\/Name>/,/<Value>/s/<Value>[^<]*/<Value>#{origin_ip}/' /home/wowza/conf/Server.xml 
      sudo service WowzaStreamingEngine restart" 

Answer 2

서버 수신기가 IP 주소를 사용자 지정 변수에로드하도록 할 수 있습니다. 그런 다음 구성 파일이이 사용자 지정 변수를 참조하게 할 수 있습니다. 이것은 "com.wowza.amazonaws.ec2.AWSEC2_METADATA_LOCAL_IPV4"와 같은 Wowza EC2 변수를 채우는 것과 같은 방법입니다. 이들은 다음의 본 구현 예는 (이것이 old post의 코드이다)이다

${com.wowza.amazonaws.ec2.AWSEC2_METADATA_LOCAL_IPV4} 

같은 Wowza 구성 파일에 추가 할 수있다.

package com.wowza.wms.plugin.amazonaws.ec2.env; 

import com.wowza.util.*; 
import com.wowza.wms.server.*; 
import com.wowza.wms.vhost.HostPort; 
import com.wowza.wms.logging.*; 

public class ServerListenerEC2Variables implements IServerNotify2 
{ 
    public static final String VARPREFIX = "com.wowza.amazonaws.ec2"; 

    public static final String VAR_AMI_ID = "AWSEC2_METADATA_AMI_ID"; 
    public static final String VAR_AMI_LAUNCH_INDEX = "AWSEC2_METADATA_AMI_LAUNCH_INDEX"; 
    public static final String VAR_AMI_MANIFEST_PATH = "AWSEC2_METADATA_AMI_MANIFEST_PATH"; 
    public static final String VAR_INSTANCE_ID = "AWSEC2_METADATA_INSTANCE_ID"; 
    public static final String VAR_INSTANCE_TYPE = "AWSEC2_METADATA_INSTANCE_TYPE"; 
    public static final String VAR_HOSTNAME = "AWSEC2_METADATA_HOSTNAME"; 
    public static final String VAR_LOCAL_HOSTNAME = "AWSEC2_METADATA_LOCAL_HOSTNAME"; 
    public static final String VAR_LOCAL_IPV4 = "AWSEC2_METADATA_LOCAL_IPV4"; 
    public static final String VAR_PUBLIC_HOSTNAME = "AWSEC2_METADATA_PUBLIC_HOSTNAME"; 
    public static final String VAR_PUBLIC_IPV4 = "AWSEC2_METADATA_PUBLIC_IPV4"; 
    public static final String VAR_RESERVATION_ID = "AWSEC2_METADATA_RESERVATION_ID"; 
    public static final String VAR_SECURITY_GROUPS = "AWSEC2_METADATA_SECURITY_GROUPS"; 
    public static final String VAR_PRODUCT_CODES = "AWSEC2_METADATA_PRODUCT_CODES"; 

    private void populateEnvironment() 
    { 
     try 
     { 
      String[] urls = { 
        "http://169.254.169.254/latest/meta-data/ami-id", 
        "http://169.254.169.254/latest/meta-data/ami-launch-index", 
        "http://169.254.169.254/latest/meta-data/ami-manifest-path", 
        "http://169.254.169.254/latest/meta-data/instance-id", 
        "http://169.254.169.254/latest/meta-data/instance-type", 
        "http://169.254.169.254/latest/meta-data/hostname", 
        "http://169.254.169.254/latest/meta-data/local-hostname", 
        "http://169.254.169.254/latest/meta-data/local-ipv4", 
        "http://169.254.169.254/latest/meta-data/public-hostname", 
        "http://169.254.169.254/latest/meta-data/public-ipv4", 
        /* "http://169.254.169.254/2007-03-01/meta-data/public-keys/", */ 
        "http://169.254.169.254/latest/meta-data/reservation-id", 
        "http://169.254.169.254/latest/meta-data/security-groups", 
        "http://169.254.169.254/latest/meta-data/product-codes", 
       }; 

      for(int i=0;i<urls.length;i++) 
      { 
       String url = urls[i]; 
       byte[] data = HTTPUtils.HTTPRequestToByteArray(url, "GET", null, null); 
       if (data != null) 
       { 
        String[] urlParts = url.split("/"); 
        if (urlParts.length > 1) 
        { 
         try 
         { 
          String key = VARPREFIX+"."+"AWSEC2_METADATA_"+urlParts[urlParts.length-1].replace("-", "_").toUpperCase(); 
          String value = new String(data, "UTF-8"); 

          System.setProperty(key, value); 
          WMSLoggerFactory.getLogger(ServerListenerEC2Variables.class).info(key+": "+value); 
         } 
         catch (Exception e) 
         { 
          WMSLoggerFactory.getLogger(ServerListenerEC2Variables.class).error("ServerListenerEC2Variables.populateEnvironment: conversion to string: "+e.toString()); 
         } 
        } 
       } 
      } 
     } 
     catch (Exception e) 
     { 
      WMSLoggerFactory.getLogger(ServerListenerEC2Variables.class).error("ServerListenerEC2Variables.populateEnvironment: "+e.toString()); 
     } 
    } 

    public void onServerConfigLoaded(IServer server) 
    { 
     populateEnvironment(); 

     Server inServer = (Server)server; 
     JMXRemoteConfig remoteConfig = inServer.getJmxRemoteConfig(); 

     while(true) 
     { 
      String ipAddress = remoteConfig.getIpAddress(); 
      if (ipAddress == null) 
       break; 

      ipAddress = SystemUtils.expandEnvironmentVariables(ipAddress); 

      WMSLoggerFactory.getLogger(ServerListenerEC2Variables.class).info("Updating JMX IpAddress: "+ipAddress); 
      remoteConfig.setIpAddress(ipAddress); 
      break; 
     } 

     while(true) 
     { 
      String ipAddress = remoteConfig.getRmiServerHostName(); 
      if (ipAddress == null) 
       break; 

      ipAddress = SystemUtils.expandEnvironmentVariables(ipAddress); 

      WMSLoggerFactory.getLogger(ServerListenerEC2Variables.class).info("Updating JMX RMIServerHostName: "+ipAddress); 
      remoteConfig.setRmiServerHostName(ipAddress); 
      break; 
     } 

     while(true) 
     { 
      String propName = "loadBalancerSenderRedirectAddress"; 
      String ipAddress = server.getProperties().getPropertyStr(propName); 
      if (ipAddress == null) 
       break; 

      ipAddress = SystemUtils.expandEnvironmentVariables(ipAddress); 

      WMSLoggerFactory.getLogger(ServerListenerEC2Variables.class).info("Updating Server.property."+propName+": "+ipAddress); 
      server.getProperties().setProperty(propName, ipAddress); 
      break; 
     }  
    } 

    public void onServerCreate(IServer server) 
    { 
    } 

    public void onServerInit(IServer server) 
    { 
    } 

    public void onServerShutdownStart(IServer server) 
    { 
    } 

    public void onServerShutdownComplete(IServer server) 
    { 
    } 

}