CREATE CONNECTION

gäller för:markerat med ja Databricks SQL markerat med ja Databricks Runtime 13.3 LTS och senare markerat med ja endast Unity Catalog

Det här kommandot skapar en extern anslutning (eller server), som representerar ett fjärrdatasystem av en viss typ, med hjälp av systemspecifika alternativ som anger platsen för fjärrsystemet och autentiseringsinformationen.

Externa anslutningar möjliggör federerade förfrågningar.

Important

Om du vill skydda autentiseringsuppgifter som lösenord och token anger du dem med hjälp av secret funktionen i stället för att ange literalvärdena direkt i OPTIONS -satsen. På så sätt kan du referera till en hemlighet som lagras i Databricks-säkerhetstjänsten i stället för att inkludera värdet för autentiseringsuppgifter i -instruktionen. Se exemplen.

Syntax

CREATE CONNECTION [IF NOT EXISTS] connection_name
  TYPE connection_type
  OPTIONS ( option value [, ...] )
  [ COMMENT comment ]

För standardefterlevnad kan du också använda SERVER i stället CONNECTIONför .

Parameterar

  • connection_name

    En unik identifierare för anslutningen på metaarkivnivå för Unity Catalog.

  • connection_type

    Identifierar typen av anslutning och måste vara en av:

    • DATABRICKS
    • HTTP gäller för: Databricks SQL markerad som ja Databricks Runtime 16.2 och senare
    • MYSQL
    • POSTGRESQL
    • REDSHIFT
    • SNOWFLAKE
    • SQLDW (Synapse)
    • SQLSERVER

  • OPTIONS

    Anger connection_type specifika parametrar som behövs för att upprätta anslutningen.

    • alternativ

      Egenskapsnyckel Nyckeln kan bestå av en eller flera identifierare avgränsade med en punkt eller en STRING literal.

      Egenskapsnycklar måste vara unika och skiftlägeskänsliga.

    • värde

      Värdet för egenskapen. Värdet måste vara ett BOOLEAN, STRING, INTEGEReller DECIMALkonstant uttryck.

      För alla alternativ som har en autentiseringsuppgift, till exempel ett lösenord eller en token, använder du secret funktionen i stället för att ange värdet direkt. Ange till exempel value för som secret('secrets.r.us', 'postgresPassword') i stället för password att ange literallösenordet.

HTTP-alternativ

gäller för: Databricks SQL kontrollera markerat ja Databricks Runtime 16.2 och senare

HTTP-anslutningstypen stöder följande alternativnycklar och värden:

  • host

    En STRING literal. Anger host_name för den externa tjänsten. Ett undantag utlöses om värdsökvägen inte är en normaliserad URL.

  • bearer_token

    Den autentiseringstoken som ska användas när du anropar den externa tjänsten. Ange token med funktionen SECRET i stället för som en STRING literal. Till exempel kan värdet bestå av secret('secrets.r.us', 'httpPassword') i stället för att ange literaltoken.

  • port En valfri INTEGER literal som anger porten. Standardvärdet är 443;

  • base_path

    En valfri STRING literal. Standardvärdet är /. Ett undantag utlöses om sökvägen innehåller en tom sträng eller en felaktig sökväg med blanksteg eller specialtecken.

Examples

Ange autentiseringsuppgifter med hjälp av secret funktionen, som du ser i följande exempel, i stället för att ange lösenord eller token direkt.

-- Create a postgresql connection.
-- Provide the user and password using the secret function rather than
-- entering them directly.
> CREATE CONNECTION postgresql_connection
    TYPE POSTGRESQL
    OPTIONS (
       host '<hostname>',
       port '5432',
       user secret('secrets.r.us', 'postgresUser'),
       password secret('secrets.r.us', 'postgresPassword'));

-- Set up a connection to Slack.
-- Provide the bearer token using the secret function rather than a literal value.
> CREATE CONNECTION slack_conn
  TYPE HTTP
  OPTIONS (
    host 'https://slack.com',
    port '443',
    base_path '/api/',
    bearer_token secret('secrets.r.us', 'slackBearerToken')
  );

-- Request to the external service
> SELECT http_request(
    conn => 'slack_conn',
    method => 'POST',
    path => '/chat.postMessage',
    json => to_json(named_struct(
      'channel', channel,
      'text', text
    ))
    headers => map(
       'Accept', "application/vnd.github+json",
    )
  );
  • Last updated on