Instalação do Snowpark Submit¶

Você pode instalar Snowpark Submit para executar cargas de trabalho do Spark orientadas a lote diretamente na infraestrutura do Snowflake.

Para instalar Snowpark Submit, conclua as seguintes etapas:

Instale Snowpark Submit usando pip.
```
pip install snowpark-submit
```
Em um arquivo connections.toml para autenticação do Snowflake, adicione uma conexão do Snowflake. Se você já tem essa conexão, pode usá-la.

Se você ainda não tem um arquivo connections.toml, crie um conforme descrito em Conexão usando o arquivo connections.toml.

Quando você tiver um arquivo connections.toml, poderá adicionar uma conexão do Snowflake a ele. Por exemplo, para adicionar uma conexão do Snowflake chamada snowpark-submit, adicione as seguintes linhas ao arquivo de configuração:
```
[snowpark-submit]
host = "<account>.snowflakecomputing.com"
port = 443
account = "<account>"
user = "test_user"
role = "test_role"
password = "<password for user>"
protocol = "https"
warehouse = "test_warehouse"
database = "test_db"
schema = "test_schema"
compute_pool = "test_compute_pool"
```

Verifique se você consegue se conectar ao Snowflake por meio do computador cliente.

Para verificar se a conexão funciona por meio de seu computador cliente, crie um arquivo .py com código que se conecta ao Snowflake.

Criar um arquivo connection_test.py e, em seguida, adicione o seguinte código:

# connection_test.py code

import sys
import snowflake.connector

conn_name = sys.argv[1]

print(f"Trying connection named {conn_name}..")
conn = snowflake.connector.connect(connection_name=conn_name)
print("Connected.")

cursor = conn.cursor()
cursor.execute("SELECT 'Connection successful'")
for col in cursor:
    print(col)

print("\nListing first 5 tables:\n")
cursor = conn.cursor()
cursor.execute('show tables limit 5')
for col in cursor:
    print(col)
print("\nDone")

Em seu ambiente virtual Python ativo, execute o seguinte comando, especificando o nome da conexão que você adicionou ao seu arquivo connections.toml.
```
python connection_test.py snowpark-submit
```

Depois de verificar se você pode se conectar ao Snowflake de seu computador cliente, poderá usar o Snowpark Submit para executar cargas de trabalho do Spark orientadas por lote diretamente na infraestrutura do Snowflake. Consulte Referência de Snowpark Submit para conferir a referência de linha de comando do Snowpark Submit ou Exemplos Snowpark Submit para ver exemplos de como usar o Snowpark Submit.