SAS(공유 액세스 서명)를 사용하여 Event Hubs 리소스에 대한 액세스 인증

SAS(공유 액세스 서명)를 사용하면 클라이언트에 부여하는 액세스 유형을 세부적으로 제어할 수 있습니다. SAS에서 설정할 수 있는 몇 가지 컨트롤은 다음과 같습니다.

• SAS가 유효한 경우 시작 시간 및 만료 시간을 포함하는 간격을 설정할 수 있습니다.
• SAS에서 부여된 권한입니다. 예를 들어 Event Hubs 네임스페이스의 SAS는 수신 대기 권한을 부여할 수 있지만 보내기 권한은 부여할 수 없습니다.
• 유효한 자격 증명을 제공하는 클라이언트만 이벤트 허브로 데이터를 보낼 수 있습니다.
• 클라이언트는 다른 클라이언트를 가장할 수 없습니다.
• 악성 클라이언트는 이벤트 허브로 데이터를 보내지 못하도록 차단할 수 있습니다.

이 문서에서는 SAS를 사용하여 Event Hubs 리소스에 대한 액세스를 인증하는 방법을 다룹니다. SAS를 사용하여 Event Hubs 리소스에 대한 액세스 권한을 부여하는 방법을 알아보려면 이 문서를 참조하세요.

SAS 인증 구성

Event Hubs 네임스페이스 또는 엔터티(이벤트 허브 또는 Kafka 토픽)에서 SAS 규칙을 구성할 수 있습니다. 소비자 그룹에 대한 SAS 규칙 구성은 현재 지원되지 않지만, 네임스페이스 또는 엔터티에 구성된 규칙을 사용하여 소비자 그룹에 대한 액세스를 보호할 수 있습니다. 다음 이미지는 샘플 엔터티에 권한 부여 규칙을 적용하는 방법을 보여 줍니다.

이 예제에서 샘플 Event Hubs 네임스페이스(ExampleNamespace)에는 eh1과 Kafka topic1이라는 두 개의 엔터티가 있습니다. 권한 부여 규칙은 엔터티 수준뿐만 아니라 네임스페이스 수준에서도 정의됩니다.

manageRuleNS, sendRuleNS 및 listenRuleNS 권한 부여 규칙은 eh1 및 topic1 모두에 적용됩니다. listenRule-eh 및 sendRule-eh 권한 부여 규칙은 eh1에만 적용되고 sendRuleT 권한 부여 규칙은 topic1에만 적용됩니다.

sendRuleNS 권한 부여 규칙을 사용하는 경우 클라이언트 애플리케이션은 eh1과 topic1 모두에 보낼 수 있습니다. sendRuleT 권한 부여 규칙을 사용하는 경우 topic1에만 세분화된 액세스를 적용하므로, 액세스에 이 규칙을 사용하는 클라이언트 애플리케이션은 이제 eh1에는 보낼 수 없고 topic1에만 보낼 수 있습니다.

공유 액세스 서명 토큰 생성

권한 부여 규칙 이름에 대한 액세스 권한이 있는 모든 클라이언트 및 해당 서명 키 중 하나는 SAS 토큰을 생성할 수 있습니다. 토큰은 다음 형식으로 문자열을 선별하여 생성됩니다.

• se - 토큰 만료 인스턴트입니다. 토큰이 만료되는 Epoch 1970년 1월 1일 00:00:00 UTC 이후의 초(UNIX Epoch)를 반영하는 정수입니다.
• skn - 권한 부여 규칙의 이름으로 SAS 키 이름입니다.
• sr - 액세스 중인 리소스의 URI입니다.
• sig - 서명입니다.

서명 문자열은 리소스 URI(이전 섹션에서 설명한 범위)를 통해 계산된 SHA-256 해시와 토큰 만료 인스턴트의 문자열 표현이며 CRLF(캐리지 리턴 및 줄 바꿈)로 구분됩니다. 해시 계산은 다음 의사 코드와 유사하며 256비트/32바이트 해시 값을 반환합니다.

SHA-256('https://<yournamespace>.servicebus.windows.net/'+'\n'+ 1438205742)

토큰은 수신자가 동일한 매개 변수를 사용하여 해시를 다시 계산할 수 있도록 발급자가 유효한 서명 키를 소유하는지 확인하여 해시되지 않은 값을 포함합니다.

리소스 URI은 액세스를 하려는 Service Bus 리소스의 전체 URI입니다. 예를 들면 http://<namespace>.servicebus.windows.net/<entityPath> 또는 sb://<namespace>.servicebus.windows.net/<entityPath>입니다. 즉, http://contoso.servicebus.windows.net/eh1과 같습니다.

URI는 %로 인코딩되어야 합니다.

이 URI로 또는 부모 계층 중 하나에 의해 지정된 엔터티에 서명에 사용된 SAS 규칙을 구성해야 합니다. 예를 들어 이전 예에서 http://contoso.servicebus.windows.net/eh1 또는 http://contoso.servicebus.windows.net입니다.

SAS 토큰은 서명 문자열에서 사용된 <resourceURI>를 접두사로 추가하는 모든 리소스에 유효합니다.

정책에서 서명(토큰) 생성

다음 섹션에서는 공유 액세스 서명 정책을 사용하여 SAS 토큰을 생성하는 방법을 보여 줍니다.

NodeJS

function createSharedAccessToken(uri, saName, saKey) { 
  if (!uri || !saName || !saKey) { 
          throw "Missing required parameter"; 
      } 
  var encoded = encodeURIComponent(uri); 
  var now = new Date(); 
  var week = 60*60*24*7;
  var ttl = Math.round(now.getTime() / 1000) + week;
  var signature = encoded + '\n' + ttl; 
  var hash = crypto.createHmac('sha256', saKey).update(signature, 'utf8').digest('base64'); 
  return 'SharedAccessSignature sr=' + encoded + '&sig=' +  
      encodeURIComponent(hash) + '&se=' + ttl + '&skn=' + saName; 
}

정책 이름 및 키 값을 사용하여 이벤트 허브에 연결하려면 AzureNamedKeyCredential 매개 변수를 사용하는 EventHubProducerClient 생성자를 사용합니다.

const producer = new EventHubProducerClient("NAMESPACE NAME.servicebus.windows.net", eventHubName, new AzureNamedKeyCredential("POLICYNAME", "KEYVALUE"));

AzureNamedKeyCredential에 대한 참조를 추가해야 합니다.

const { AzureNamedKeyCredential } = require("@azure/core-auth");

코드를 사용하여 생성한 SAS 토큰을 사용하려면 AzureSASCredential 매개 변수를 사용하는 EventHubProducerClient 생성자를 사용합니다.

var token = createSharedAccessToken("https://NAMESPACENAME.servicebus.windows.net", "POLICYNAME", "KEYVALUE");
const producer = new EventHubProducerClient("NAMESPACENAME.servicebus.windows.net", eventHubName, new AzureSASCredential(token));

AzureSASCredential에 대한 참조를 추가해야 합니다.

const { AzureSASCredential } = require("@azure/core-auth");

Java

private static String GetSASToken(String resourceUri, String keyName, String key)
  {
      long epoch = System.currentTimeMillis()/1000L;
      int week = 60*60*24*7;
      String expiry = Long.toString(epoch + week);

      String sasToken = null;
      try {
          String stringToSign = URLEncoder.encode(resourceUri, "UTF-8") + "\n" + expiry;
          String signature = getHMAC256(key, stringToSign);
          sasToken = "SharedAccessSignature sr=" + URLEncoder.encode(resourceUri, "UTF-8") +"&sig=" +
                  URLEncoder.encode(signature, "UTF-8") + "&se=" + expiry + "&skn=" + keyName;
      } catch (UnsupportedEncodingException e) {

          e.printStackTrace();
      }

      return sasToken;
  }


public static String getHMAC256(String key, String input) {
    Mac sha256_HMAC = null;
    String hash = null;
    try {
        sha256_HMAC = Mac.getInstance("HmacSHA256");
        SecretKeySpec secret_key = new SecretKeySpec(key.getBytes(), "HmacSHA256");
        sha256_HMAC.init(secret_key);
        Encoder encoder = Base64.getEncoder();

        hash = new String(encoder.encode(sha256_HMAC.doFinal(input.getBytes("UTF-8"))));

    } catch (InvalidKeyException e) {
        e.printStackTrace();
    } catch (NoSuchAlgorithmException e) {
        e.printStackTrace();
   } catch (IllegalStateException e) {
        e.printStackTrace();
    } catch (UnsupportedEncodingException e) {
        e.printStackTrace();
    }

    return hash;
}

PHP

function generateSasToken($uri, $sasKeyName, $sasKeyValue) 
{ 
    $targetUri = strtolower(rawurlencode(strtolower($uri))); 
    $expires = time(); 	
    $expiresInMins = 60; 
    $week = 60*60*24*7;
    $expires = $expires + $week; 
    $toSign = $targetUri . "\n" . $expires; 
    $signature = rawurlencode(base64_encode(hash_hmac('sha256', 			
     $toSign, $sasKeyValue, TRUE))); 
    
    $token = "SharedAccessSignature sr=" . $targetUri . "&sig=" . $signature . "&se=" . $expires . 		"&skn=" . $sasKeyName; 
    return $token; 
}

C#

private static string createToken(string resourceUri, string keyName, string key)
{
    TimeSpan sinceEpoch = DateTime.UtcNow - new DateTime(1970, 1, 1);
    var week = 60 * 60 * 24 * 7;
    var expiry = Convert.ToString((int)sinceEpoch.TotalSeconds + week);
    string stringToSign = HttpUtility.UrlEncode(resourceUri) + "\n" + expiry;
    using (var hmac = new HMACSHA256(Encoding.UTF8.GetBytes(key)))
    {
        var signature = Convert.ToBase64String(hmac.ComputeHash(Encoding.UTF8.GetBytes(stringToSign)));
        var sasToken = String.Format(CultureInfo.InvariantCulture, "SharedAccessSignature sr={0}&sig={1}&se={2}&skn={3}", HttpUtility.UrlEncode(resourceUri), HttpUtility.UrlEncode(signature), expiry, keyName);
        return sasToken;
    }
}

PowerShell

[Reflection.Assembly]::LoadWithPartialName("System.Web")| out-null
$URI="myNamespace.servicebus.windows.net/myEventHub/"
$Access_Policy_Name="RootManageSharedAccessKey"
$Access_Policy_Key="myPrimaryKey"
#Token expires now+300
$Expires=([DateTimeOffset]::Now.ToUnixTimeSeconds())+300
$SignatureString=[System.Web.HttpUtility]::UrlEncode($URI)+ "`n" + [string]$Expires
$HMAC = New-Object System.Security.Cryptography.HMACSHA256
$HMAC.key = [Text.Encoding]::ASCII.GetBytes($Access_Policy_Key)
$Signature = $HMAC.ComputeHash([Text.Encoding]::ASCII.GetBytes($SignatureString))
$Signature = [Convert]::ToBase64String($Signature)
$SASToken = "SharedAccessSignature sr=" + [System.Web.HttpUtility]::UrlEncode($URI) + "&sig=" + [System.Web.HttpUtility]::UrlEncode($Signature) + "&se=" + $Expires + "&skn=" + $Access_Policy_Name
$SASToken

BASH

get_sas_token() {
    local EVENTHUB_URI='EVENTHUBURI'
    local SHARED_ACCESS_KEY_NAME='SHAREDACCESSKEYNAME'
    local SHARED_ACCESS_KEY='SHAREDACCESSKEYVALUE'
    local EXPIRY=${EXPIRY:=$((60 * 60 * 24))} # Default token expiry is 1 day

    local ENCODED_URI=$(echo -n $EVENTHUB_URI | jq -s -R -r @uri)
    local TTL=$(($(date +%s) + $EXPIRY))
    local UTF8_SIGNATURE=$(printf "%s\n%s" $ENCODED_URI $TTL | iconv -t utf8)

    local HASH=$(echo -n "$UTF8_SIGNATURE" | openssl sha256 -hmac $SHARED_ACCESS_KEY -binary | base64)
    local ENCODED_HASH=$(echo -n $HASH | jq -s -R -r @uri)

    echo -n "SharedAccessSignature sr=$ENCODED_URI&sig=$ENCODED_HASH&se=$TTL&skn=$SHARED_ACCESS_KEY_NAME"
}

SAS를 사용하여 Event Hubs 게시자 인증

이벤트 게시자는 이벤트 허브에 대한 가상 엔드포인트를 정의합니다. 게시자는 이벤트 허브에 메시지를 보내는 데만 사용할 수 있고 메시지를 받을 때는 사용할 수 없습니다.

일반적으로 이벤트 허브에서는 클라이언트당 하나의 게시자를 사용합니다. 이벤트 허브의 게시자에게 전달되는 모든 메시지는 해당 이벤트 허브 내의 큐에 삽입됩니다. 게시자는 세분화된 액세스 제어를 사용하도록 설정합니다.

각 Event Hubs 클라이언트는 클라이언트에 업로드되는 고유 토큰을 할당받습니다. 고유한 각 토큰이 고유한 다른 게시자에 액세스 권한을 부여하도록 토큰이 생성됩니다. 토큰을 보유한 클라이언트는 하나의 게시자에게만 보낼 수 있으며 다른 게시자에게는 보낼 수 없습니다. 여러 클라이언트가 동일한 토큰을 공유하는 경우 각 클라이언트가 게시자를 공유합니다.

모든 토큰은 SAS 키와 함께 할당됩니다. 일반적으로 모든 토큰은 동일한 키로 서명됩니다. 클라이언트는 키를 인식하지 못하므로 클라이언트는 토큰을 제조할 수 없습니다. 클라이언트는 만료될 때까지 동일한 토큰에 대해 작동합니다.

예를 들어 Event Hubs에 대한 보내기/게시로 범위가 한정된 권한 부여 규칙을 정의하려면 보내기 권한 부여 규칙을 정의해야 합니다. 네임스페이스 수준에서 수행하거나 특정 엔터티(이벤트 허브 인스턴스 또는 토픽)에 더 세부적인 범위를 제공할 수 있습니다. 세부적인 액세스로 범위가 지정된 클라이언트 또는 애플리케이션을 Event Hubs 게시자라고 합니다. 이렇게 하려면 다음 단계를 수행합니다.

1. 게시하려는 엔터티에 대한 SAS 키를 만들어 보내기 범위를 할당합니다. 자세한 내용은 공유 액세스 권한 부여 정책을 참조하세요.

2. 1단계에서 생성한 키를 사용하여 특정 게시자에 대한 만료 시간이 있는 SAS 토큰을 생성합니다. 샘플 코드는 정책에서 서명(토큰) 생성을 참조하세요.

3. 토큰을 게시자 클라이언트에 제공합니다. 게시자 클라이언트는 해당 토큰이 액세스 권한을 부여한 엔터티와 게시자에만 보낼 수 있습니다.

   토큰이 만료되면 클라이언트는 엔터티에 대한 보내기/게시 액세스 권한을 잃게 됩니다.

SAS를 사용하여 Event Hubs 소비자 인증

Event Hubs 생산자에 의해 생성된 데이터를 사용하는 백 엔드 애플리케이션을 인증하려면, 해당 클라이언트에 Event Hubs 네임스페이스나 이벤트 허브 인스턴스 또는 토픽에 할당된 관리 권한 또는 수신 대기 권한이 있어야 Event Hubs 토큰 인증을 사용할 수 있습니다. 데이터는 소비자 그룹을 사용하여 Event Hubs에서 사용됩니다. SAS 정책은 세부적인 범위를 제공하지만, 이는 소비자 수준이 아니라 엔터티 수준에서만 정의됩니다. 즉, 네임스페이스 수준 또는 이벤트 허브 또는 토픽 수준에서 정의된 권한이 해당 엔터티의 소비자 그룹에 적용됩니다.

로컬/SAS 키 인증 사용 안 함

특정 조직 보안 요구 사항의 경우 로컬/SAS 키 인증을 완전히 사용하지 않도록 설정하고 Microsoft Entra ID 기반 인증을 사용해야 할 수 있습니다. 이는 Azure Event Hubs에 연결하는 데 권장되는 방법입니다. Azure Portal 또는 Azure Resource Manager 템플릿을 사용하여 Event Hubs 네임스페이스 수준에서 로컬/SAS 키 인증을 사용하지 않도록 설정할 수 있습니다.

포털을 통해 로컬/SAS 키 인증 사용 안 함

Azure Portal을 사용하여 특정 Event Hubs 네임스페이스에 대한 로컬/SAS 키 인증을 사용하지 않도록 설정할 수 있습니다.

1. Azure Portal에서 Event Hubs 네임스페이스로 이동합니다.

2. 개요 페이지에서 다음 이미지에 표시된 대로 로컬 인증에 대해 사용을 선택합니다.

   

3. 로컬 인증 팝업에서 사용 안 함을 선택하고 확인을 선택합니다.

   

템플릿을 사용하여 로컬/SAS 키 인증 사용 안 함

다음 ARM 템플릿(Azure Resource Manager 템플릿)에 표시된 대로 disableLocalAuth 속성을 true로 설정하여 특정 Event Hubs 네임스페이스에 대한 로컬 인증을 사용하지 않도록 설정할 수 있습니다.

"resources":[
      {
         "apiVersion":"[variables('ehVersion')]",
         "name":"[parameters('eventHubNamespaceName')]",
         "type":"Microsoft.EventHub/Namespaces",
         "location":"[variables('location')]",
         "sku":{
            "name":"Standard",
            "tier":"Standard"
         },
         "resources": [
    {
      "apiVersion": "2017-04-01",
      "name": "[parameters('eventHubNamespaceName')]",
      "type": "Microsoft.EventHub/Namespaces",
      "location": "[resourceGroup().location]",
      "sku": {
        "name": "Standard"
      },
      "properties": {
        "isAutoInflateEnabled": "true",
        "maximumThroughputUnits": "7", 
        "disableLocalAuth": true
      },
      "resources": [
        {
          "apiVersion": "2017-04-01",
          "name": "[parameters('eventHubName')]",
          "type": "EventHubs",
          "dependsOn": [
            "[concat('Microsoft.EventHub/namespaces/', parameters('eventHubNamespaceName'))]"
          ],
          "properties": {
            "messageRetentionInDays": "[parameters('messageRetentionInDays')]",
            "partitionCount": "[parameters('partitionCount')]"
          }

        }
      ]
    }
  ]

샘플

• 공유 액세스 자격 증명 또는 기본 Azure 자격 증명 ID를 사용하여 이벤트 허브에 이벤트를 게시하는 방법을 알아보려면 이 GitHub 위치의 .NET 샘플 #6을 참조하세요.
• 공유 액세스 자격 증명 또는 기본 Azure 자격 증명 ID를 사용하여 이벤트를 사용 또는 처리하는 방법을 알아보려면 이 GitHub 위치의 .NET 샘플 #5를 참조하세요.

다음 단계

다음 문서를 참조하세요.

• SAS를 사용한 권한 부여
• Azure RBAC(역할 기반 액세스 제어)를 사용하여 권한 부여
• Event Hubs에 대해 자세히 알아보기

다음 관련 문서를 참조하세요.

• Microsoft Entra ID를 사용하여 애플리케이션에서 Azure Event Hubs에 대한 요청을 인증합니다.
• Event Hubs 리소스에 액세스하기 위해 Microsoft Entra ID를 사용하여 관리 ID 인증
• Microsoft Entra ID를 사용하여 Event Hubs 리소스에 대한 액세스 권한 부여
• 공유 액세스 서명을 사용하여 Event Hubs 리소스에 대한 액세스 권한 부여