[Service Bus] Add perf pipeline (Azure#23819)

* starter code

* service-bus perf pipeline

* checkpoint

* Revert "checkpoint"

This reverts commit 057e5e8.

* test update

* copy stress resource

* Update sdk/servicebus/service-bus/perf.yml

* body - message

* Improve defaults in perf.yml

* Fix typo in regex

* Add receive-batch to tests

* ["inherit", "inherit", "inherit", "ipc"]

* close the sender too

* Update sdk/test-utils/perf/src/multicore.ts

* changelog

* Revert "Update sdk/test-utils/perf/src/multicore.ts"

This reverts commit 2717a00.

* Revert "changelog"

This reverts commit 2e3bdc2.

* remove console.log

* Revert "["inherit", "inherit", "inherit", "ipc"]"

This reverts commit 829ea40.

Co-authored-by: Mike Harder <mharder@microsoft.com>

Author: HarshaNalluru

sdk/servicebus/perf-tests/service-bus/README.md

@@ -13,14 +13,14 @@ To test sending messages in batches
 
 > `npm run perf-test:node -- BatchSendTest --warmup 2 --duration 7 --parallel 2`
 
-> `npm run perf-test:node -- BatchSendTest --warmup 1 --duration 25 --iterations 2 --parallel 32 --size 10240 --numberOfMessages 10`
+> `npm run perf-test:node -- BatchSendTest --warmup 1 --duration 25 --iterations 2 --parallel 32 --size 10240 --batch-size 10`
 
 To test `receiveMessages` - receiving messages in batches
 
-> `npm run perf-test:node -- BatchReceiveTest --duration 5 --size 2000 --number-of-messages 10000 --size-in-bytes 2000 --max-message-count 50`
+> `npm run perf-test:node -- BatchReceiveTest --duration 5 --number-of-messages 10000 --message-size 2000 --max-message-count 50`
 
 To test `subscribe` - receiving a stream of messages
 
-> `npm run perf-test:node -- SubscribeTest --duration 5 --size 2000 --mcc 1000`
+> `npm run perf-test:node -- SubscribeTest --duration 5 --message-size 2000 --messages 10000 --mcc 1000`
 
 _Note: For more default options, refer [Perf-Framework-Default-Options](https://github.com/Azure/azure-sdk-for-js/blob/main/sdk/test-utils/perf/README.md#keyconcepts)._

sdk/servicebus/perf-tests/service-bus/test/receiveBatch.spec.ts

@@ -24,13 +24,14 @@ export class BatchReceiveTest extends ServiceBusTest<ReceiverOptions> {
       required: true,
       description: "Size of each message body in bytes",
       shortName: "size",
-      longName: "size-in-bytes",
+      longName: "message-size",
       defaultValue: 2000,
     },
     "max-message-count": {
       required: true,
       description: "Max number of messages to receive",
       shortName: "max-receive",
+      longName: "max-message-count",
       defaultValue: 50,
     },
   };
@@ -86,6 +87,5 @@ export async function sendMessages(
     );
     await sender.sendMessages(currentBatch);
     count = count + currentBatch.count;
-    console.log(`${count} messages sent so far`);
   }
 }

sdk/servicebus/perf-tests/service-bus/test/sendBatch.spec.ts

@@ -25,7 +25,7 @@ export class BatchSendTest extends ServiceBusTest<SendTestOptions> {
       required: true,
       description: "Number of messages per send",
       shortName: "num",
-      longName: "numberOfMessages",
+      longName: "batch-size",
       defaultValue: 10,
     },
   };

sdk/servicebus/perf-tests/service-bus/test/subscribe.spec.ts

@@ -32,7 +32,7 @@ export class SubscribeTest extends EventPerfTest<ReceiverOptions> {
       required: true,
       description: "Size of each message body in bytes",
       shortName: "size",
-      longName: "size-in-bytes",
+      longName: "message-size",
       defaultValue: 2000,
     },
     "max-concurrent-calls": {
@@ -64,6 +64,7 @@ export class SubscribeTest extends EventPerfTest<ReceiverOptions> {
     } = this.parsedOptions;
 
     await sendMessages(sender, numberOfMessages, messageBodySize);
+    await sender.close();
   }
 
   setup() {

sdk/servicebus/perf-tests/service-bus/tsconfig.json

@@ -2,7 +2,7 @@
   "extends": "../../../../tsconfig.package",
   "compilerOptions": {
     "module": "commonjs",
-    "noEmit": true
+    "outDir": "./dist-esm",
   },
   "compileOnSave": true,
   "exclude": ["node_modules"],

sdk/servicebus/service-bus/perf-resources.bicep

@@ -0,0 +1,40 @@
+@description('The base resource name.')
+param baseName string = resourceGroup().name
+
+@description('The client OID to grant access to test resources.')
+param testApplicationOid string
+
+var apiVersion = '2017-04-01'
+var location = resourceGroup().location
+var authorizationRuleName_var = '${baseName}/RootManageSharedAccessKey'
+
+resource servicebus 'Microsoft.ServiceBus/namespaces@2018-01-01-preview' = {
+  name: baseName
+  location: location
+  sku: {
+    name: 'Standard'
+    tier: 'Standard'
+  }
+  properties: {
+    zoneRedundant: false
+  }
+}
+
+resource authorizationRuleName 'Microsoft.ServiceBus/namespaces/AuthorizationRules@2015-08-01' = {
+  name: authorizationRuleName_var
+  location: location
+  properties: {
+    rights: [
+      'Listen'
+      'Manage'
+      'Send'
+    ]
+  }
+  dependsOn: [
+    servicebus
+  ]
+}
+
+output SERVICEBUS_CONNECTION_STRING string = listKeys(resourceId('Microsoft.ServiceBus/namespaces/authorizationRules', baseName, 'RootManageSharedAccessKey'), apiVersion).primaryConnectionString
+output SERVICEBUS_ENDPOINT string = replace(servicebus.properties.serviceBusEndpoint, ':443/', '')
+output testApplicationOid string = testApplicationOid

sdk/servicebus/service-bus/perf.yml

@@ -0,0 +1,37 @@
+parameters:
+  - name: operatingSystems
+    displayName: OperatingSystems (list of operating systems to run)
+    type: string
+    default: 'Linux'
+  - name: packageVersions
+    displayName: PackageVersions (regex of package versions to run)
+    type: string
+    default: '7|source'
+  - name: tests
+    displayName: Tests (regex of tests to run)
+    type: string
+    default: '^(send-event-batch|subscribe|receive-batch)$'
+  - name: arguments
+    displayName: Arguments (regex of arguments to run)
+    type: string
+    default: '.*'
+  - name: iterations
+    displayName: Iterations (times to run each test)
+    type: number
+    default: '5'
+  - name: additionalArguments
+    displayName: AdditionalArguments (passed to PerfAutomation)
+    type: string
+    default: ' '
+
+extends:
+  template: /eng/pipelines/templates/jobs/perf.yml
+  parameters:
+    operatingSystems: ${{ parameters.operatingSystems }}
+    serviceDirectory: servicebus/service-bus
+    services: "^servicebus$"
+    packageVersions: ${{ parameters.packageVersions }}
+    tests: ${{ parameters.tests }}
+    arguments: ${{ parameters.arguments }}
+    iterations: ${{ parameters.iterations }}
+    additionalArguments: ${{ parameters.additionalArguments }}