Blog

import mysql.connector
import schedule
import time

def check_and_process_data():
    # Veritabanı bağlantısı
    mydb = mysql.connector.connect(
      host="localhost",
      user="kullanici_adi",
      password="sifre",
      database="veritabani_adi"
    )
    
    # Bağlantı kontrolü
    if mydb.is_connected():
        print("Veritabanına başarıyla bağlandı.")
    
    # Veri kontrolü ve işlem
    mycursor = mydb.cursor()
    mycursor.execute("SELECT deger FROM tablo_adi")
    result = mycursor.fetchone()
    
    if result[0] == 0:
        # İşlem yapılacak kodlar buraya gelecek
        print("Veri 0'a eşit, işlem yapılıyor...")
    else:
        print("Veri 0'a eşit değil, işlem yapılmayacak.")
    
    # Veritabanı bağlantısını kapatma
    mydb.close()

# Her 10 saniyede bir veri kontrolü yap
schedule.every(10).seconds.do(check_and_process_data)

while True:
    schedule.run_pending()
    time.sleep(1)

Yukarıdaki örnekte, schedule modülü kullanılarak check_and_process_data adlı bir fonksiyon belirli aralıklarla çağrılır. Bu örnekte her 10 saniyede bir veri kontrolü yapmak için schedule.every(10).seconds.do(check_and_process_data) kullanılır.

check_and_process_data fonksiyonu, veritabanına bağlanır, veriyi kontrol eder ve gerekli işlemleri yapar. Bu fonksiyonu kendi işlemlerinize göre düzenleyebilirsiniz.

Sonra, while True döngüsü ile schedule.run_pending() fonksiyonu çağrılır ve program belirli aralıklarla veri kontrolü yapmaya devam eder. time.sleep(1) fonksiyonu, döngünün her bir turunda 1 saniye bekletme işlemi gerçekleştirir.

Bu şekilde, program belirli aralıklarla veri kontrolü yapacak ve 0 olan veriler için belirlediğiniz işlemi gerçekleştirecektir.

import mysql.connector

config = {
    'host': 'localhost',
    'user': 'your_username',
    'password': 'your_password',
    'database': 'your_database'
}

cnx = mysql.connector.connect(**config)
cursor = cnx.cursor()

query = "SELECT * FROM your_table"
cursor.execute(query)

result = cursor.fetchall()

cursor.close()
cnx.close()

print(result)

import mysql.connector

config = {
    'host': 'localhost',
    'user': 'your_username',
    'password': 'your_password',
    'database': 'your_database'
}

cnx = mysql.connector.connect(**config)
cursor = cnx.cursor()

query = "SELECT * FROM your_table WHERE your_column = 0 LIMIT 1"
cursor.execute(query)

result = cursor.fetchone()

cursor.close()
cnx.close()

print(result)

import mysql.connector

config = {
    'host': 'localhost',
    'user': 'your_username',
    'password': 'your_password',
    'database': 'your_database'
}

cnx = mysql.connector.connect(**config)
cursor = cnx.cursor()

query = "SELECT your_column FROM your_table WHERE ..."
cursor.execute(query)
result = cursor.fetchone()
number = result[0]  # Sayıyı alın

for i in range(number):
    print("Döngü adımı:", i+1)
    # Döngü işlemlerini burada gerçekleştirin

cursor.close()
cnx.close()

import mysql.connector

config = {
    'host': 'localhost',
    'user': 'your_username',
    'password': 'your_password',
    'database': 'your_database'
}

cnx = mysql.connector.connect(**config)
cursor = cnx.cursor()

name = "John Doe"  # Aktarmak istediğiniz değişkenin içeriği

query = "INSERT INTO your_table (column_name) VALUES (%s)"
cursor.execute(query, (name,))

cnx.commit()

cursor.close()
cnx.close()

Python programını yeniden başlatmak için aşağıdaki yöntemleri kullanabilirsiniz:

1. exit() Kullanma:

pythonCopy codeimport sys

# Programın yeniden başlatılması gerektiği bir noktada
sys.exit()

sys.exit() çağrısı, programın anında sonlanmasını sağlar. Program sonlandığında, Python yürütme ortamından çıkar ve program otomatik olarak yeniden başlatılmaz.

2. os.execv() Kullanma:

pythonCopy codeimport os
import sys

# Programın yeniden başlatılması gerektiği bir noktada
python = sys.executable
os.execl(python, python, *sys.argv)

Bu yöntem, os.execv() fonksiyonunu kullanarak Python yürütülebilir dosyasını (interpreter) tekrar çağırmak suretiyle programı yeniden başlatır. sys.executable, çalışan Python yürütücüsünün tam yolunu temsil eder.

Bu yöntemler programı doğrudan yeniden başlatır. Ancak, programın mevcut durumunu ve değişkenlerini korumazlar. Eğer mevcut durumu korumak ve değişkenleri aktarmak isterseniz, başka bir yöntem kullanmanız gerekebilir.

3. Subprocess Modülünü Kullanma:

pythonCopy codeimport sys
import subprocess

# Programın yeniden başlatılması gerektiği bir noktada
subprocess.call([sys.executable] + sys.argv)

Bu yöntemde, subprocess.call() fonksiyonu kullanılarak ayrı bir süreç başlatılır ve mevcut Python programını yeniden çağırır. sys.argv, programın komut satırı argümanlarını temsil eder.

Bu yöntem, programı yeniden başlatırken mevcut durumu ve değişkenleri korumaya yardımcı olur.

Hangi yöntemi kullanacağınız, ihtiyaçlarınıza ve programınızın gereksinimlerine bağlıdır. İlgili noktada uygun olan yöntemi seçerek programınızı yeniden başlatabilirsiniz.

<?php

// API erişim bilgileri
$apiUrl = 'https://example.com:2083/execute/StatCollector/get_service_statuses';
$apiKey = 'API_ANAHTARINIZ';

// cURL isteği oluşturma
$curl = curl_init();

curl_setopt_array($curl, array(
  CURLOPT_URL => $apiUrl,
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => '',
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 0,
  CURLOPT_FOLLOWLOCATION => true,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => 'POST',
  CURLOPT_POSTFIELDS => '[{ "module": "stat-collector", "function": "get_service_statuses", "apiversion": 3, "args": {} }]',
  CURLOPT_HTTPHEADER => array(
    'Authorization: cpanel ' . $apiKey,
    'Content-Type: application/json'
  ),
));

// API isteğini gerçekleştirme
$response = curl_exec($curl);

// cURL işlemini kapatma
curl_close($curl);

// Yanıtı görüntüleme
echo $response;
?>

<?php
// HP switch'in IP adresini ve yönetici kullanıcı adı/şifresini tanımlayın
$switchIP = '192.168.0.1';
$username = 'admin';
$password = 'password';

// Komutları içeren bir dizi oluşturun
$commands = [
    'show interfaces',
    'show vlan',
    'show running-config'
];

// Komutları HP switch'e gönderen bir fonksiyon tanımlayın
function sendCommandsToSwitch($switchIP, $username, $password, $commands) {
    // SSH bağlantısını kurun
    $connection = ssh2_connect($switchIP, 22);
    if (!$connection) {
        die('SSH bağlantısı kurulamadı.');
    }

    // SSH kimlik doğrulamasını gerçekleştirin
    if (!ssh2_auth_password($connection, $username, $password)) {
        die('Kimlik doğrulaması başarısız.');
    }

    // Komutları işleyin
    foreach ($commands as $command) {
        // SSH oturumu başlatın
        $shell = ssh2_shell($connection, 'vt102', null, 80, 40, SSH2_TERM_UNIT_CHARS);
        if (!$shell) {
            die('SSH oturumu başlatılamadı.');
        }

        // Komutu gönderin
        fwrite($shell, $command . PHP_EOL);

        // Çıktıyı alın
        $output = '';
        while ($line = fgets($shell)) {
            $output .= $line;
        }

        // Çıktıyı ekrana yazdırın veya başka bir şekilde işleyin
        echo 'Komut: ' . $command . PHP_EOL;
        echo 'Çıktı: ' . $output . PHP_EOL;

        // SSH oturumunu kapatın
        fclose($shell);
    }

    // SSH bağlantısını kapatın
    ssh2_disconnect($connection);
}

// Komutları switch'e gönderin
sendCommandsToSwitch($switchIP, $username, $password, $commands);
?>