2 # SPDX-License-Identifier: Apache-2.0
4 from onapsdk.configuration import settings
5 from oransdk.dmaap.oran_dmaap import OranDmaap
6 from oransdk.a1sim.a1sim import A1sim
9 logger = logging.getLogger("")
10 logger.setLevel(logging.DEBUG)
11 fh = logging.StreamHandler()
12 fh_formatter = logging.Formatter('%(asctime)s %(levelname)s %(lineno)d:%(filename)s(%(process)d) - %(message)s')
13 fh.setFormatter(fh_formatter)
17 logger.info("Get all the topics")
18 topiclist = dmaap.get_all_topics(BASIC_AUTH)
19 logger.info("response is: %s", topiclist)
22 logger.info("Create new topic")
23 topic = '{ "topicName": "unauthenticated.SEC_FAULT_OUTPUT", "topicDescription": "test topic", "partitionCount": 1, "replicationCnCount": 1, "transactionEnabled": "false"}'
24 response = dmaap.create_topic(topic, BASIC_AUTH)
25 logger.info("response is: %s", response)
28 logger.info("Get topics again")
29 topiclist = dmaap.get_all_topics(BASIC_AUTH)
30 logger.info("response is: %s", topiclist)
34 logger.info("Get ric version for ost")
36 version1 = a1sim.check_version(settings.A1SIM_OST_URL)
37 version2 = a1sim.check_version(settings.A1SIM_STD1_URL)
38 version3 = a1sim.check_version(settings.A1SIM_STD2_URL)