Compare commits
11 Commits
6c3278e340
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
| 50647dd094 | |||
| aee4a1b7fb | |||
| 1c91c1a0db | |||
| 247b2f4576 | |||
| 641747634a | |||
| a33ad6b6c9 | |||
| 63b89b59ae | |||
| bf56431785 | |||
| 142c0b60df | |||
| c304b9903c | |||
| 36070e012d |
@@ -0,0 +1 @@
|
||||
modulo_os/__pycache__/
|
||||
@@ -0,0 +1,7 @@
|
||||
PORT=5000
|
||||
|
||||
DB_HOST=
|
||||
DB_USER=
|
||||
DB_PASSWORD=
|
||||
DB_NAME=
|
||||
DB_PORT=
|
||||
@@ -0,0 +1,2 @@
|
||||
.venv/
|
||||
.env
|
||||
Binary file not shown.
@@ -0,0 +1,79 @@
|
||||
from flask import Flask, jsonify, request
|
||||
from flask_cors import CORS
|
||||
import os
|
||||
from dotenv import load_dotenv
|
||||
from db import get_connection
|
||||
|
||||
#Carrega arquivo de variáveis de ambiente (.env)
|
||||
load_dotenv()
|
||||
#Carrega variável de ambiente PORT. Essa variável contém a porta TCP utilizada na APIREST
|
||||
PORT = os.getenv("PORT")
|
||||
|
||||
#Cria objeto Flask. Esse objeto é necessário para utilização do FLASK
|
||||
#(módulo python para criação de APIs REST).
|
||||
app = Flask(__name__)
|
||||
#Aplica cors no objeto Flask
|
||||
CORS(app)
|
||||
|
||||
#Criar rota de saúde da aplicação
|
||||
@app.route("/health")
|
||||
def health():
|
||||
return jsonify({"message" : "API Flask version 1.0!!!"})
|
||||
|
||||
#=============================================================
|
||||
|
||||
@app.route("/produtos",methods=["GET"])
|
||||
def listar_produtos():
|
||||
conexao = get_connection()
|
||||
cursor = conexao.cursor(dictionary=True)
|
||||
|
||||
cursor.execute("select * from produto")
|
||||
produtos = cursor.fetchall()
|
||||
|
||||
cursor.close()
|
||||
conexao.close()
|
||||
|
||||
return jsonify(produtos)
|
||||
|
||||
#=============================================================
|
||||
|
||||
@app.route("/produtos/<int:id>", methods=["GET"])
|
||||
def listar_produto_id(id):
|
||||
conexao = get_connection()
|
||||
cursor = conexao.cursor(dictionary=True)
|
||||
|
||||
cursor.execute("Select * from produto where id = %s", (id,))
|
||||
produto = cursor.fetchone()
|
||||
|
||||
cursor.close()
|
||||
conexao.close()
|
||||
|
||||
if produto is None:
|
||||
return jsonify({"erro" : "Produto não encontrado"}), 404
|
||||
|
||||
return jsonify(produto)
|
||||
|
||||
#=============================================================
|
||||
|
||||
@app.route("/produtos",methods=["POST"])
|
||||
def criar_produto():
|
||||
dados = request.get_json()
|
||||
nome = dados.get("nome")
|
||||
preco = dados.get("preco")
|
||||
estoque = dados.get("estoque")
|
||||
if nome is None or preco is None or estoque is None:
|
||||
return jsonify({"erro" : "Produto inválido"}), 400
|
||||
conexao = get_connection()
|
||||
cursor = conexao.cursor()
|
||||
sql = "insert into produto (nome, preco, estoque) values (%s, %s, %s)"
|
||||
cursor.execute(sql,(nome, preco, estoque))
|
||||
conexao.commit()
|
||||
novo_id = cursor.lastrowid
|
||||
cursor.close()
|
||||
conexao.close()
|
||||
return jsonify({"id" : novo_id, "nome": nome, "preco" : preco, "estoque" : estoque}), 201
|
||||
|
||||
|
||||
#Inicializa o servidor da APIRest
|
||||
if __name__ == "__main__":
|
||||
app.run(port=PORT, debug=True)
|
||||
@@ -0,0 +1,17 @@
|
||||
import os
|
||||
import mysql.connector
|
||||
from dotenv import load_dotenv
|
||||
|
||||
load_dotenv()
|
||||
|
||||
def get_connection():
|
||||
return mysql.connector.connect(
|
||||
host=os.getenv("DB_HOST"),
|
||||
user=os.getenv("DB_USER"),
|
||||
password=os.getenv("DB_PASSWORD"),
|
||||
database=os.getenv("DB_NAME"),
|
||||
port=os.getenv("DB_PORT")
|
||||
)
|
||||
|
||||
|
||||
|
||||
@@ -0,0 +1,30 @@
|
||||
<!DOCTYPE html>
|
||||
<html lang="pt-br">
|
||||
<head>
|
||||
<meta charset="UTF-8">
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||
<link rel="stylesheet" href="style.css">
|
||||
<title>Produtos</title>
|
||||
</head>
|
||||
<body>
|
||||
|
||||
<h1>Lista de produtos</h1>
|
||||
<main>
|
||||
|
||||
<table>
|
||||
<thead>
|
||||
<tr>
|
||||
<th>Nome</th>
|
||||
<th>Preço</th>
|
||||
<th>Estoque</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody id="conteudo_tabela">
|
||||
|
||||
</tbody>
|
||||
</table>
|
||||
</main>
|
||||
|
||||
<script src="script.js"></script>
|
||||
</body>
|
||||
</html>
|
||||
@@ -0,0 +1,20 @@
|
||||
async function carregarProdutos(){
|
||||
const resposta = await fetch("http://localhost:5000/produtos");
|
||||
if (!resposta.ok){
|
||||
throw new Error("Não foi possível carregar a lista")
|
||||
}
|
||||
const produtos = await resposta.json();
|
||||
let tbody = document.querySelector("tbody");
|
||||
produtos.forEach(produto => {
|
||||
let linha = document.createElement("tr");
|
||||
linha.innerHTML = ` <td>${produto.nome}</td>
|
||||
<td>${produto.preco}</td>
|
||||
<td>${produto.estoque}</td>
|
||||
`
|
||||
tbody.appendChild(linha);
|
||||
});
|
||||
}
|
||||
|
||||
window.addEventListener("load", () => {
|
||||
carregarProdutos();
|
||||
})
|
||||
@@ -0,0 +1,24 @@
|
||||
/*
|
||||
Seletor {
|
||||
propriedade1 : valor;
|
||||
propriedade2 : valor;
|
||||
...
|
||||
propriedadeN : valor;
|
||||
}
|
||||
*/
|
||||
|
||||
|
||||
/* CSS de RESET */
|
||||
* {
|
||||
margin : 0;
|
||||
padding: 0;
|
||||
}
|
||||
|
||||
h1 {
|
||||
width : 300px;
|
||||
background-color: brown;
|
||||
padding: 20px;
|
||||
border: 10px solid black;
|
||||
text-align: center;
|
||||
margin: 0 auto;
|
||||
}
|
||||
@@ -0,0 +1,11 @@
|
||||
blinker==1.9.0
|
||||
click==8.3.3
|
||||
colorama==0.4.6
|
||||
Flask==3.1.3
|
||||
flask-cors==6.0.2
|
||||
itsdangerous==2.2.0
|
||||
Jinja2==3.1.6
|
||||
MarkupSafe==3.0.3
|
||||
mysql-connector-python==9.7.0
|
||||
python-dotenv==1.2.2
|
||||
Werkzeug==3.1.8
|
||||
@@ -0,0 +1,16 @@
|
||||
#Criar tabela produto
|
||||
create table produto (
|
||||
id int auto_increment primary key,
|
||||
nome varchar(100) not null,
|
||||
preco decimal(10,2) not null,
|
||||
estoque int not null
|
||||
);
|
||||
|
||||
#Carga incial do banco
|
||||
insert into produto (nome,preco,estoque)
|
||||
values ('Bola',12.50,10);
|
||||
insert into produto (nome,preco,estoque)
|
||||
values ('PS5',3950.50,5);
|
||||
|
||||
#Exemplo de consulta
|
||||
#select * from produto;
|
||||
@@ -0,0 +1,14 @@
|
||||
aluno = {
|
||||
"nome" : "João",
|
||||
"matricula" : "10011454",
|
||||
"ira" : 8.5,
|
||||
"idade" : 35,
|
||||
"ativo" : True,
|
||||
"dicionario" : { "teste" : "A" },
|
||||
"notas" : []
|
||||
}
|
||||
|
||||
print(aluno["nome"])
|
||||
print(aluno.get("nome"))
|
||||
print(aluno.get("dicionario").get("teste"))
|
||||
print(aluno.keys())
|
||||
@@ -0,0 +1,44 @@
|
||||
import tkinter as tk
|
||||
from tkinter import scrolledtext
|
||||
import socket
|
||||
import threading
|
||||
|
||||
def ouvir_servidor(socket_servidor):
|
||||
while True:
|
||||
mensagem = socket_servidor.recv(80000)
|
||||
area_mensagens.config(state="normal")
|
||||
area_mensagens.insert(tk.END, mensagem.decode() + "\n")
|
||||
area_mensagens.config(state="disabled")
|
||||
|
||||
socket_servidor = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
socket_servidor.connect(("10.209.1.45",5000))
|
||||
|
||||
thread = threading.Thread(target=ouvir_servidor, args=[socket_servidor,])
|
||||
thread.start()
|
||||
|
||||
janela = tk.Tk()
|
||||
janela.title("Chat do IFRN")
|
||||
|
||||
rotulo_mensagem = tk.Label(janela, text="Digite sua mensagem")
|
||||
rotulo_mensagem.pack()
|
||||
|
||||
entrada_mensagem = tk.Entry(janela, width=80)
|
||||
entrada_mensagem.pack()
|
||||
|
||||
def clicar():
|
||||
mensagem = entrada_mensagem.get()
|
||||
print(mensagem)
|
||||
socket_servidor.send(mensagem.encode())
|
||||
entrada_mensagem.delete(0, tk.END)
|
||||
area_mensagens.config(state="normal")
|
||||
area_mensagens.insert(tk.END, mensagem + "\n")
|
||||
area_mensagens.config(state="disabled")
|
||||
|
||||
botao = tk.Button(janela, text="Enviar", command=clicar)
|
||||
botao.pack()
|
||||
|
||||
area_mensagens = scrolledtext.ScrolledText(janela)
|
||||
area_mensagens.pack()
|
||||
area_mensagens.config(state="disabled")
|
||||
|
||||
janela.mainloop()
|
||||
@@ -0,0 +1,15 @@
|
||||
# Modelo de importação diferente. Não precisará mais
|
||||
# usar a palavra socket (módulo) antes dos recursos
|
||||
from socket import *
|
||||
|
||||
# Criar objeto socket
|
||||
cliente = socket(AF_INET, SOCK_STREAM)
|
||||
|
||||
# Abrir conexão
|
||||
cliente.connect(("127.0.0.1",3000))
|
||||
|
||||
# Enviar mensagem
|
||||
cliente.send("Olá, servidor!".encode())
|
||||
|
||||
mensagem = cliente.recv(1024)
|
||||
print(f"Mensagem recebida {mensagem.decode()}")
|
||||
@@ -0,0 +1,32 @@
|
||||
import socket
|
||||
import threading
|
||||
import time
|
||||
|
||||
servidor = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
servidor.bind(("0.0.0.0",5000))
|
||||
servidor.listen()
|
||||
print("Servidor inicializado!!!")
|
||||
|
||||
clientes = []
|
||||
|
||||
def ouvir_cliente(cliente):
|
||||
funcionar = True
|
||||
while True:
|
||||
try:
|
||||
if funcionar:
|
||||
mensagem = cliente.recv(80000)
|
||||
for socket_cliente in clientes:
|
||||
if socket_cliente != cliente:
|
||||
socket_cliente.send(mensagem)
|
||||
else:
|
||||
time.sleep(5)
|
||||
except Exception as e:
|
||||
print(f"Ocorreu um erro inesperado: {e}")
|
||||
funcionar = False
|
||||
|
||||
while True:
|
||||
cliente, endereco_cliente = servidor.accept()
|
||||
print("Cliente conectado:", endereco_cliente)
|
||||
clientes.append(cliente)
|
||||
thread = threading.Thread(target=ouvir_cliente, args=[cliente,])
|
||||
thread.start()
|
||||
@@ -0,0 +1,28 @@
|
||||
# Biblioteca padrão para utilização de sockets
|
||||
import socket
|
||||
|
||||
# Criar um objeto socket com AF_INET (IPV4) e SOCK_STREAM (TCP)
|
||||
servidor = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
|
||||
# Estabelecer vínculo com um endereço e uma porta
|
||||
servidor.bind(("0.0.0.0",3000))
|
||||
|
||||
print("Servidor inicializado...")
|
||||
|
||||
# Começa a ouvir tentativas de conexão
|
||||
servidor.listen()
|
||||
|
||||
while True:
|
||||
# Aceitar conexão, recebendo o objeto socket da conexão e
|
||||
# o endereço de quem se conectou
|
||||
conexao, endereco = servidor.accept()
|
||||
print(f"Endereco do cliente: {endereco}")
|
||||
|
||||
# Recebendo mensagem do cliente. Tenho que converter
|
||||
# bytes para string (decode)
|
||||
mensagem = conexao.recv(1024).decode()
|
||||
print(f"Mensagem recebida: {mensagem}")
|
||||
|
||||
# Enviar mensagem. Precisa ser em bytes (decode)
|
||||
conexao.send("OK! Sou o servidor".encode())
|
||||
|
||||
@@ -0,0 +1,3 @@
|
||||
numero = int(input("Digite um número: "))
|
||||
for i in range(11):
|
||||
print(f"{numero}x{i}={numero*i}")
|
||||
@@ -0,0 +1,20 @@
|
||||
import threading
|
||||
import time
|
||||
|
||||
|
||||
# Função que será executada pela thread
|
||||
def executar(nome_thread, n_iteracoes):
|
||||
for i in range(n_iteracoes):
|
||||
print(f"Nome da thread: {nome_thread}")
|
||||
time.sleep(2) # Parar por 2s
|
||||
|
||||
t1 = threading.Thread(target=executar,args=["Thread1",15,])
|
||||
t2 = threading.Thread(target=executar,args=["Thread2",10,])
|
||||
|
||||
t1.start()
|
||||
t2.start()
|
||||
|
||||
t1.join()
|
||||
t2.join()
|
||||
|
||||
print("Final da thread principal")
|
||||
Reference in New Issue
Block a user