Add files via upload

dataproc/list_clusters.py

@@ -1 +1,62 @@
-#!/usr/bin/env python# Licensed 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."""Sample command-line program to list Cloud Dataproc clusters in a region.Example usage:python list_clusters.py --project_id=my-project-id --region=global"""import argparsefrom google.cloud import dataproc_v1from google.cloud.dataproc_v1.gapic.transports import (    cluster_controller_grpc_transport)# [START dataproc_list_clusters]def list_clusters(dataproc, project, region):    """List the details of clusters in the region."""    for cluster in dataproc.list_clusters(project, region):        print(('{} - {}'.format(cluster.cluster_name,                                cluster.status.State.Name(                                    cluster.status.state))))# [END dataproc_list_clusters]def main(project_id, region):    if region == 'global':        # Use the default gRPC global endpoints.        client_transport = ''    else:        # Use a regional gRPC endpoint. See:        # https://cloud.google.com/dataproc/docs/concepts/regional-endpoints        client_transport = (            cluster_controller_grpc_transport.ClusterControllerGrpcTransport(                address='{}-dataproc.googleapis.com:443'.format(region)))    dataproc_cluster_client = dataproc_v1.ClusterControllerClient(        client_transport)    list_clusters(dataproc_cluster_client, project_id, region)if __name__ == '__main__':    parser = argparse.ArgumentParser(        description=__doc__, formatter_class=(            argparse.RawDescriptionHelpFormatter))    parser.add_argument(        '--project_id', help='Project ID to access.', required=True)    parser.add_argument(        '--region', help='Region of clusters to list.', required=True)    args = parser.parse_args()    main(args.project_id, args.region)
+#!/usr/bin/env python
+# Licensed 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.
+"""Sample command-line program to list Cloud Dataproc clusters in a region.
+
+Example usage:
+python list_clusters.py --project_id=my-project-id --region=global
+
+"""
+import argparse
+from google.cloud import dataproc_v1
+from google.cloud.dataproc_v1.gapic.transports import (
+    cluster_controller_grpc_transport)
+
+
+# [START dataproc_list_clusters]
+def list_clusters(dataproc, project, region):
+    """List the details of clusters in the region."""
+    for cluster in dataproc.list_clusters(project, region):
+        print(('{} - {}'.format(cluster.cluster_name,
+                                cluster.status.State.Name(
+                                    cluster.status.state))))
+# [END dataproc_list_clusters]
+
+
+def main(project_id, region):
+
+    if region == 'global':
+        # Use the default gRPC global endpoints.
+        client_transport = ''
+    else:
+        # Use a regional gRPC endpoint. See:
+        # https://cloud.google.com/dataproc/docs/concepts/regional-endpoints
+        client_transport = (
+            cluster_controller_grpc_transport.ClusterControllerGrpcTransport(
+                address='{}-dataproc.googleapis.com:443'.format(region)))
+    dataproc_cluster_client = dataproc_v1.ClusterControllerClient(
+        client_transport)
+
+    list_clusters(dataproc_cluster_client, project_id, region)
+
+
+if __name__ == '__main__':
+    parser = argparse.ArgumentParser(
+        description=__doc__, formatter_class=(
+            argparse.RawDescriptionHelpFormatter))
+    parser.add_argument(
+        '--project_id', help='Project ID to access.', required=True)
+    parser.add_argument(
+        '--region', help='Region of clusters to list.', required=True)
+
+    args = parser.parse_args()
+    main(args.project_id, args.region)