1.16.2. 항목 생성

절차

1. 다음 요청 형식을 사용하여 주제를 생성합니다.

   구문

   POST
   Action=CreateTopic
   &Name=TOPIC_NAME
   [&Attributes.entry.1.key=amqp-exchange&Attributes.entry.1.value=EXCHANGE]
   [&Attributes.entry.2.key=amqp-ack-level&Attributes.entry.2.value=none|broker|routable]
   [&Attributes.entry.3.key=verify-ssl&Attributes.entry.3.value=true|false]
   [&Attributes.entry.4.key=kafka-ack-level&Attributes.entry.4.value=none|broker]
   [&Attributes.entry.5.key=use-ssl&Attributes.entry.5.value=true|false]
   [&Attributes.entry.6.key=ca-location&Attributes.entry.6.value=FILE_PATH]
   [&Attributes.entry.7.key=OpaqueData&Attributes.entry.7.value=OPAQUE_DATA]
   [&Attributes.entry.8.key=push-endpoint&Attributes.entry.8.value=ENDPOINT]

   요청 매개 변수는 다음과 같습니다.

   • endpoint : 알림을 보낼 끝점의 URL입니다.
   • OpaqueData: 불투명 데이터가 주제 구성에 설정되고 해당 주제에서 트리거한 모든 알림에 추가됩니다.

   • HTTP 끝점:

     • URL: http[s]://FQDN[: PORT ]
     • 포트 기본값은 다음과 같습니다 : 그에 따라 HTTP[S]에 80/443을 사용합니다.
     • verify-ssl: 클라이언트에서 서버 인증서를 검증할지 여부를 나타냅니다. 기본값은 true입니다.By default, this is true.

   • AMQP0.9.1 끝점:

     • URL: amqp://[USER : PASSWORD @] FQDN [: PORT][/VHOST].
     • 사용자 및 암호의 기본값은 guest 및 guest 입니다.
     • 사용자 및 암호는 HTTPS에서만 제공할 수 있습니다. 그렇지 않으면 주제 생성 요청이 거부됩니다.
     • 포트 기본값은: 5672입니다.
     • vhost 기본값은 "/"입니다.
     • AMQP-exchange: 교환이 있어야 하며 주제를 기반으로 메시지를 라우팅할 수 있어야 합니다. AMQP0.9.1의 필수 매개변수입니다. 동일한 엔드포인트를 가리키는 다른 주제는 동일한 교환기를 사용해야 합니다.

     • AMQP-ack-level: 최종 대상으로 메시지가 전달되기 전에 브로커가 지속되기 전에 브로커가 지속되므로 결국 인정을 종료해야 합니다. 세 가지 승인 방법이 있습니다.

       • None: 브로커에 전송되는 경우 메시지가 배달되는 것으로 간주됩니다.
       • broker: 기본적으로 브로커가 승인한 경우 메시지가 배달되는 것으로 간주됩니다.

       • 라우팅 가능: 브로커가 소비자로 라우팅할 수 있는 경우 전달되는 메시지가 표시됩니다.

         참고

         특정 매개 변수의 키와 값은 동일한 줄 또는 특정 순서로 상주할 필요는 없지만 동일한 인덱스를 사용해야 합니다. 특성 인덱싱은 순차적이거나 특정 값에서 시작할 필요가 없습니다.

         참고

         topic-name 은 AMQP 주제를 위해 사용됩니다.

   • Kafka 끝점:

     • URL: kafka://[USER: PASSWORD @] FQDN[: PORT].
     • 기본적으로 use-ssl 이 false 로 설정된 경우. use-ssl 이 true 로 설정되면 브로커 연결에 보안 연결이 사용됩니다.
     • ca-location 이 제공되고 보안 연결이 사용되는 경우 브로커를 인증하는 기본 CA 대신 지정된 CA가 사용됩니다.
     • 사용자 및 암호는 HTTP[S]를 통해서만 제공할 수 있습니다. 그렇지 않으면topic 생성 요청이 거부됩니다.
     • 사용자 및 암호는 use-ssl 과 함께 제공될 수 있지만 그렇지 않은 경우 브로커에 대한 연결이 실패합니다.
     • 포트 기본값은: 9092입니다.

     • Kafka-ack-level: 메시지가 최종 목적지로 전달되기 전에 브로커에서 지속될 수 있기 때문에 승인이 필요하지 않습니다. 두 가지 승인 방법이 있습니다.

       • None: 브로커에 전송되는 경우 메시지가 배달되는 것으로 간주됩니다.
       • broker: 기본적으로 브로커가 승인한 경우 메시지가 배달되는 것으로 간주됩니다.

2. 다음 형식으로 응답을 생성합니다.

   구문

   <CreateTopicResponse xmlns="https://sns.amazonaws.com/doc/2010-03-31/">
       <CreateTopicResult>
           <TopicArn></TopicArn>
       </CreateTopicResult>
       <ResponseMetadata>
           <RequestId></RequestId>
       </ResponseMetadata>
   </CreateTopicResponse>

   참고

   응답의 ARMN(Amazon Resource Name)의 주제는 arn:aws:sns:ZONE_GROUP:TENANT : topic

   다음은 AMQP0.9.1 끝점의 예입니다.

   구문

   "client.create_topic(Name='my-topic' , Attributes={'push-endpoint': 'amqp://127.0.0.1:5672', 'amqp-exchange': 'ex1', 'amqp-ack-level': 'broker'})"