Add token examples of python (#25)

* Add oauth2 examples of python

Signed-off-by: xiaolong.ran <rxl@apache.org>

* Add token examples of nodejs

Signed-off-by: xiaolong.ran <rxl@apache.org>

* ignore package-lock.json file

Signed-off-by: xiaolong.ran <rxl@apache.org>

* Fix a little

Signed-off-by: xiaolong.ran <rxl@apache.org>

* fix comments

Signed-off-by: xiaolong.ran <rxl@apache.org>

* Add pulsar-client and pulsar-perf

Signed-off-by: xiaolong.ran <rxl@apache.org>

* update readme

Signed-off-by: xiaolong.ran <rxl@apache.org>

* Improve pulsarctl example

Signed-off-by: xiaolong.ran <rxl@apache.org>

* fix comments

Signed-off-by: xiaolong.ran <rxl@apache.org>

* fix pulsarctl code example

Signed-off-by: xiaolong.ran <rxl@apache.org>

* fix comments

Signed-off-by: xiaolong.ran <rxl@apache.org>

Author: wolfstudy

.gitignore

@@ -19,6 +19,9 @@
 *.tar.gz
 *.rar
 
+node_modules
+package-lock.json
+
 # virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
 hs_err_pid*
 

cloud/README.md

@@ -2,15 +2,87 @@
 
 ## Programming Languages
 
-This directory includes examples of Apache Pulsar client applications, showcasing producers and consumers, written in various programming languages. The README for each language walks through the necessary steps to run each example. When each client establishes a connection with the Pulsar cluster through OAuth2, it needs to obtain the specified options from the Pulsar cluster and OAuth2 services. [How to get OAuth2 options](#How to get OAuth2 options) explains how you get these options.
+This directory includes examples of Apache Pulsar client applications, showcasing producers and consumers, written in various programming languages. The README for each language walks through the necessary steps to run each example. When each client establishes a connection with the Pulsar cluster through **OAuth2** or **Token**.
+ 
+For the OAuth2, it needs to obtain the specified options from the Pulsar cluster and OAuth2 services. [How to get OAuth2 options](#How to get OAuth2 options) explains how you get these options.
 
 Currently, we support the following three languages to connect through OAuth2:
 
 - Java
 - Go
 - CPP
 
-For clients in other languages, you can connect through token, reference to [here](https://pulsar.apache.org/docs/en/security-tls-transport/#client-configuration).
+The following clients and Pulsar CLI tools are supported to connect to cluster through the Token. And [How to get Token options](#How to get Token options) explains how you get these options.
+
+- Java
+- Go
+- CPP
+- Python
+- CSharp(TODO)
+- NodeJS
+- pulsarctl
+- pulsar-admin
+- pulsar-client
+- pulsar-perf
+
+## How to get token options
+
+When you use Token to connect to Pulsar cluster, you need to provide the following options:
+
+- `SERVICE_URL`
+- `WEB_SERVICE_URL`
+- `AUTH_PARAMS`
+
+For the `SERVICE_URL` field, you can get the **hostname** through the following command:
+
+```shell script
+$ snctl get pulsarclusters [CLUSTER_NAME] -n [NAMESPACE] -o json | jq '.spec.serviceEndpoints[0].dnsName'
+```
+
+Output:
+
+```text
+api.test.cloud.xxx.streamnative.dev
+```
+
+A `SERVICE_URL` is a combination of protocol, hostname and port, so an example of a complete `SERVICE_URL` is as follows:
+
+
+```text
+pulsar://api.test.cloud.xxx.streamnative.dev:6650
+
+# For tls
+pulsar+ssl://api.test.cloud.xxx.streamnative.dev:6651
+```
+
+For the `WEB_SERVICE_URL` field, you can get the **hostname** through the following command:
+
+```shell script
+$ snctl get pulsarclusters [CLUSTER_NAME] -n [NAMESPACE] -o json | jq '.spec.serviceEndpoints[0].dnsName'
+```
+
+Output:
+
+```text
+api.test.cloud.xxx.streamnative.dev
+```
+
+A `WEB_SERVICE_URL` is a combination of protocol, hostname and port, so an example of a complete `WEB_SERVICE_URL` is as follows:
+
+```text
+http://api.test.cloud.xxx.streamnative.dev:8080
+
+# For tls
+https://api.test.cloud.xxx.streamnative.dev:8443
+```
+
+For the `AUTH_PARAMS` field, you can get it through the following command:
+
+```shell script
+$ snctl auth get-token [INSTANCE] [flags]
+```
+
+> Tips: In code implementation, for safety and convenience, you can consider setting `AUTH_PARAMS` as an environment variable.
 
 ## How to get OAuth2 options
 

cloud/cpp/ConnectByOAuth2.cc

@@ -0,0 +1,36 @@
+
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+#include <iostream>
+#include <pulsar/Client.h>
+
+using namespace pulsar;
+
+int main() {
+    ClientConfiguration config;
+    std::string params = R"({
+    "issuer_url": "https://dev-kt-aa9ne.us.auth0.com/oauth/token",
+    "private_key": "../../pulsar-broker/src/test/resources/authentication/token/cpp_credentials_file.json",
+    "audience": "https://dev-kt-aa9ne.us.auth0.com/api/v2/"})";
+
+    config.setAuth(pulsar::AuthOauth2::create(params));
+
+    Client client("pulsar+ssl://cluster.test.us-east4.streamnative.test.g.sn2.dev:6651", config);
+    client.close();
+}

cloud/cpp/ConnectByToken.cc

@@ -0,0 +1,31 @@
+
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+#include <iostream>
+#include <pulsar/Client.h>
+
+using namespace pulsar;
+
+int main() {
+    ClientConfiguration config;
+    config.setAuth(AuthToken::createWithToken("AUTH_PARAMS"));
+    Client client(SERVICE_URL, config);
+
+    client.close();
+}

cloud/cpp/README.md

@@ -4,6 +4,14 @@ Produce message to and consume message from a Pulsar cluster using [Apache pulsa
 
 # Prerequisites
 
+## Linux
+
+Since 2.1.0 release, Pulsar ships pre-built RPM and Debian packages. You can download and install those packages directly.
+
+For more information, refer to [here](https://pulsar.apache.org/docs/en/client-libraries-cpp/#supported-platforms).
+
+## MacOS
+
 Pulsar releases are available in the Homebrew core repository. You can install the C++ client library with the following command. The package is installed with the library and headers.
 
 ```shell script
@@ -16,6 +24,8 @@ In this example, the producer will publish data to the `topic-1` in your Pulsar
 The content of each message payload is  `content`.
 The consumer will receive the message from the `topic-1` and `ack` the receipt of each message received.
 
+> Tips: The following code example uses the OAuth2 connection method. If you want to connect to the Pulsar cluster using Token, please refer to the implementation of **connectByToken.cc**.
+
 1. Run the consumer, and start to receiving the message from `topic-1`:
 
 ```bash

cloud/csharp/README.md

@@ -0,0 +1,3 @@
+# Overview
+
+This document describes how to produce message to and consume message from a Pulsar cluster using [Apache pulsar-dotpulsar](https://github.com/apache/pulsar-dotpulsar).

cloud/go/README.md

@@ -17,6 +17,8 @@ In this example, the producer publishes data to the `topic-1` in your Pulsar clu
 The content of each message payload is a combination of `hello-` and a digital (0-9) (e.g: `hello-0`).
 The consumer receives the message from the `topic-1` and `acknowledges` each received message.
 
+> Tips: The following code example uses the OAuth2 connection method. If you want to connect to the Pulsar cluster using Token, please refer to the implementation of **connectByToken.go**.
+
 1. Run the consumer, and start to receiving the message from `topic-1`:
 
 ```bash

cloud/go/connectByToken.go

@@ -0,0 +1,34 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+package main
+
+import (
+	"github.com/apache/pulsar-client-go/pulsar"
+	"log"
+)
+
+func main() {
+	client, err := pulsar.NewClient(pulsar.ClientOptions{
+		URL:            SERVICE_URL,
+		Authentication: pulsar.NewAuthenticationToken(AUTH_PARAMS),
+	})
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer client.Close()
+}

cloud/java/README.md

@@ -7,14 +7,16 @@ This document describes how to produce messages to and consume messages from a A
 - Java: 1.8+
 - Pulsar broker: 2.7.0-742fc5c9b+
 
-> You can get this tarball from [bintray](https://bintray.com/streamnative/maven/org.apache.pulsar/2.7.0-742fc5c9b). When the 2.6.1 release is complete, you can also use the official 2.6.1 version.
+> You can get this tarball from [bintray](https://bintray.com/streamnative/maven/org.apache.pulsar/2.7.0-742fc5c9b). When Pulsar 2.6.1 is released, you can also use the official 2.6.1 version.
 
 # Example
 
 In this example, the producer publishes messages to the `topic-1` in your Pulsar cluster.
 The content of each message payload is a combination of `my-message-` and a digital (0-9) (e.g: `my-message-0`).
 The consumer receives the message from the `topic-1` and `acknowledges` each received message.
 
+> Tips: The following code example uses the OAuth2 connection method. If you want to connect to the Pulsar cluster using Token, please refer to the implementation of **connectByToken.java**.
+
 1. Run the consumer.
 
 ```shell script

cloud/java/src/main/java/io/streamnative/examples/oauth2/ConnectByOauth2.java

@@ -22,7 +22,7 @@
 import org.apache.pulsar.client.impl.auth.oauth2.AuthenticationFactoryOAuth2;
 
 public class ConnectByOauth2 {
-    public static void main(String[] args) throws Exception{
+    public static void main(String[] args) throws Exception {
         String issuerUrl = "https://dev-kt-aa9ne.us.auth0.com/oauth/token";
         String credentialsUrl = "file:///path/to/KeyFile.json";
         String audience = "https://dev-kt-aa9ne.us.auth0.com/api/v2/";