添加凭据,以将 BigQuery 连接到 Cloud SQL。
深入探索
如需查看包含此代码示例的详细文档,请参阅以下内容:
代码示例
Java
试用此示例之前,请按照 BigQuery 快速入门:使用客户端库中的 Java 设置说明进行操作。如需了解详情,请参阅 BigQuery Java API 参考文档。
如需向 BigQuery 进行身份验证,请设置应用默认凭据。 如需了解详情,请参阅为客户端库设置身份验证。
import com.google.cloud.bigquery.connection.v1.CloudSqlCredential;
import com.google.cloud.bigquery.connection.v1.CloudSqlProperties;
import com.google.cloud.bigquery.connection.v1.Connection;
import com.google.cloud.bigquery.connection.v1.CreateConnectionRequest;
import com.google.cloud.bigquery.connection.v1.LocationName;
import com.google.cloud.bigqueryconnection.v1.ConnectionServiceClient;
import java.io.IOException;
// Sample to create a connection with cloud MySql database
public class CreateConnection {
public static void main(String[] args) throws IOException {
// TODO(developer): Replace these variables before running the sample.
String projectId = "MY_PROJECT_ID";
String location = "MY_LOCATION";
String connectionId = "MY_CONNECTION_ID";
String database = "MY_DATABASE";
String instance = "MY_INSTANCE";
String instanceLocation = "MY_INSTANCE_LOCATION";
String username = "MY_USERNAME";
String password = "MY_PASSWORD";
String instanceId = String.format("%s:%s:%s", projectId, instanceLocation, instance);
CloudSqlCredential cloudSqlCredential =
CloudSqlCredential.newBuilder().setUsername(username).setPassword(password).build();
CloudSqlProperties cloudSqlProperties =
CloudSqlProperties.newBuilder()
.setType(CloudSqlProperties.DatabaseType.MYSQL)
.setDatabase(database)
.setInstanceId(instanceId)
.setCredential(cloudSqlCredential)
.build();
Connection connection = Connection.newBuilder().setCloudSql(cloudSqlProperties).build();
createConnection(projectId, location, connectionId, connection);
}
static void createConnection(
String projectId, String location, String connectionId, Connection connection)
throws IOException {
try (ConnectionServiceClient client = ConnectionServiceClient.create()) {
LocationName parent = LocationName.of(projectId, location);
CreateConnectionRequest request =
CreateConnectionRequest.newBuilder()
.setParent(parent.toString())
.setConnection(connection)
.setConnectionId(connectionId)
.build();
Connection response = client.createConnection(request);
System.out.println("Connection created successfully :" + response.getName());
}
}
}
Python
试用此示例之前,请按照 BigQuery 快速入门:使用客户端库中的 Python 设置说明进行操作。如需了解详情,请参阅 BigQuery Python API 参考文档。
如需向 BigQuery 进行身份验证,请设置应用默认凭据。 如需了解详情,请参阅为客户端库设置身份验证。
from google.cloud import bigquery_connection_v1 as bq_connection
"""This sample shows how to create a BigQuery connection with a Cloud SQL for MySQL database"""
def main() -> None:
# TODO(developer): Set all variables for your Cloud SQL for MySQL connection.
project_id = "your-project-id" # set project_id
location = "US" # set location
# See: https://cloud.google.com/bigquery/docs/locations for a list of
# available locations.
database = "my-database" # set database name
username = "my-username" # set database username
password = "my-password" # set database password
cloud_sql_conn_name = "" # set the name of your connection
transport = "grpc" # Set the transport to either "grpc" or "rest"
cloud_sql_credential = bq_connection.CloudSqlCredential(
{
"username": username,
"password": password,
}
)
cloud_sql_properties = bq_connection.CloudSqlProperties(
{
"type_": bq_connection.CloudSqlProperties.DatabaseType.MYSQL,
"database": database,
"instance_id": cloud_sql_conn_name,
"credential": cloud_sql_credential,
}
)
create_mysql_connection(project_id, location, cloud_sql_properties, transport)
def create_mysql_connection(
project_id: str,
location: str,
cloud_sql_properties: bq_connection.CloudSqlProperties,
transport: str,
) -> None:
connection = bq_connection.types.Connection({"cloud_sql": cloud_sql_properties})
client = bq_connection.ConnectionServiceClient(transport=transport)
parent = client.common_location_path(project_id, location)
request = bq_connection.CreateConnectionRequest(
{"parent": parent, "connection": connection}
)
response = client.create_connection(request)
print(f"Created connection successfully: {response.name}")
后续步骤
如需搜索和过滤其他 Google Cloud 产品的代码示例,请参阅 Google Cloud 示例浏览器。