with db_session:
db.generate_mapping(create_tables=False)
print(select(g for g in Games)[:10])
@bot.message_handler(content_types=['animation'])
def get_gif2(message):
file_id = message.animation.file_id
file_info = bot.get_file(file_id)
downloaded_file = bot.download_file(file_info.file_path)
src = str(message.from_user.id) + '.gif'
with open(src, 'wb') as new_file:
new_file.write(downloaded_file)
bot.reply_to(message, "Фото добавлено")
myqr.run(src)
with open(src, 'rb') as photo:
bot.send_animation(message.chat.id, photo)
get_menu(message)
from fastapi import FastAPI, Request
from fastapi.responses import JSONResponse
from fastapi.routing import APIRoute
from datetime import datetime, timedelta
def save_token_middleware(request: Request, call_next):
# Выполнение кода перед обработкой запроса
response = call_next(request)
# Выполнение кода после обработки запроса
if "access_token" in response.body:
access_token = response.json().get("access_token")
username = response.json().get("sub")
expiration_time = datetime.now() + timedelta(minutes=15)
# Здесь можно сохранить токен в базу данных
# используя модуль для работы с БД
# например, SQLAlchemy или Tortoise ORM
return response
# Создаем экземпляр приложения
app = FastAPI()
# Регистрируем middleware
app.router.route_class = APIRoute
app.middleware("http")(save_token_middleware)
# Обработчик запроса
@app.post("/users/auth", response_model=schemas.Token, tags=["users"])
def authenticate_user(user: schemas.UserAuthenticate, db: Session = Depends(get_db)):
db_user = crud.get_user_username(db, username=user.username)
if db_user is None:
raise HTTPException(status_code=403, detail="Username or password is incorrect")
else:
is_password_correct = authenti.username_password(db, user)
if is_password_correct is False:
raise HTTPException(status_code=403, detail="Username or password is incorrect")
else:
access_token_expires = timedelta(minutes=ACCESS_TOKEN_EXPIRE_MINUTES)
access_token = authenti.encode_jwt(
data={"sub": user.username}, expires_delta=access_token_expires)
return {"access_token": access_token, "token_type": "Bearer"}
# Найти все элементы с классом 'rowmenu'
menu_items = browser.find_elements(By.CLASS_NAME, 'rowmenu')
# Кликнуть на второй элемент
menu_items[1].click()
options.add_argument(r"user-data-dir=C:\Users\HOME\AppData\Local\Google\Chrome\New User Data")
from selenium import webdriver
import time
# Запускаем Chrome в автоматическом режиме
driver = webdriver.Chrome()
# Загружаем нужный сайт
driver.get("https://example.com")
# Находим элементы, которые нужно заполнить, и заполняем их
input1 = driver.find_element_by_name("input1")
input1.send_keys("значение1")
input2 = driver.find_element_by_name("input2")
input2.send_keys("значение2")
# Отправляем запрос
submit_button = driver.find_element_by_name("submit")
submit_button.click()
# Ждем 10 секунд
time.sleep(10)
# Закрываем браузер
driver.quit()
y = np.array(y)
logging.info(f'{user_id=} {user_full_name=} {time.asctime()}')
import threading
import file1
import file2
def run_in_thread(func):
def wrapper(*args, **kwargs):
thread = threading.Thread(target=func, args=args, kwargs=kwargs)
thread.start()
return wrapper
@run_in_thread
def run_function_1():
file1.test()
@run_in_thread
def run_function_2():
file2.test()
def on_startup():
run_function_1()
run_function_2()
executor.start_polling(dp, skip_updates=True, on_startup=on_startup)
treasure_x = 0
import re
# Используем регулярное выражение, чтобы найти user_id в ссылке
match = re.search(r'tg://user\?id=(\d+)', mention)
# Если ссылка была найдена
if match:
# Извлекаем user_id из ссылки
user_id = int(match.group(1))
print(user_id)
import sys
# Проверяем, есть ли у нас два аргумента - IP адрес и порт прокси
if len(sys.argv) != 3:
print("Неправильное количество аргументов")
sys.exit(1)
# Извлекаем IP адрес и порт из аргументов
proxy_ip = sys.argv[1]
proxy_port = sys.argv[2]
import requests
response = requests.get('my_url', auth=('Web', '12345678'))
if response.status_code == 409:
print(response.text)
from skpy import SkypeEventLoop, SkypeCallEvent
class MySkype(SkypeEventLoop):
def onSkypeCallEvent(self, event: SkypeCallEvent):
# Обработка события звонка
if event.type == "INCOMING":
# Обработка входящего звонка
pass
elif event.type == "OUTGOING":
# Обработка исходящего звонка
pass