Міндет және алғышарттар

Бір SELECT сұрауымен шектеулі SQL жазбаларын оқып, тексеру CSV файлын жасау.

Бұл мысал демонстрациялық деректер мен баптауларды қолданады. Өндірістік қабылдаушыларды қоспас бұрын күтілетін нәтижені өз ортаңызда тексеріңіз. Мына идентификаторлар: demo_* мысал ретінде берілген: редакторда өз оқу қосылымдарыңызды немесе дереккөздеріңізді таңдаңыз. Төмендегі JSON дайын тасымалдау архивін емес, блоктар мен байланыстар құрылымын көрсетеді.

Қосылым demo_sql — мысал оқу SQL дерекқоры. Барлық мекенжай, пайдаланушы және құпия граф JSON ішінде емес, қосылым менеджерінде бапталады.

Оқу кіріс деректері

order_idstatusamount
101open120
102closed70
103open30

Блоктар, байланыстар және нақты баптаулар

Түсіндірме схемаҮлкейту ↗13. SQL: ашық тапсырыстарды таңдау. Мысал құрылымы: 2 блок, 1 байланыс. Түйін идентификаторлары мен порттары сақталған.
13-ағын схемасы

13-мысал құрылымы: 2 блок, 1 байланыс. Бапталған графтың түйін идентификаторлары мен порттары сақталған.

Конструкторға көрсетілген блоктарды қосып, әрқайсының қасиеттерін ашыңыз және осы мәндерді орнатыңыз. Мына атаулар: demo_* оқу дереккөздері мен қосылымдарын анықтайды.

БлокБаптау
1
Қосылым
sql
  • Рөл: source
  • Қосылым: demo_sql
  • Сыртқы нысан:
    • Оқу тәсілі: query
    • Сұрау: SELECT order_id, amount FROM demo_orders WHERE status = 'open' ORDER BY order_id
2
Деректер экспорты
out
  • Пішім: csv
  • Файл атауы: open_orders
  • Мақсаты: download
  • Бөлгіш: ;
  • Уақыт белдеуі: Europe/Kyiv

Порт байланыстары

  • sql out → out in
JSON түріндегі толық граф конфигурациясы
{
  "version": 3,
  "nodes": [
    {
      "id": "sql",
      "type": "connection",
      "label": "sql",
      "config": {
        "role": "source",
        "connection_id": "demo_sql",
        "external": {
          "source_mode": "query",
          "query": "SELECT order_id, amount FROM demo_orders WHERE status = 'open' ORDER BY order_id"
        }
      }
    },
    {
      "id": "out",
      "type": "export",
      "label": "out",
      "config": {
        "format": "csv",
        "filename": "open_orders",
        "destination": "download",
        "delimiter": ";",
        "timezone": "Europe/Kyiv"
      }
    }
  ],
  "edges": [
    {
      "source": "sql",
      "target": "out",
      "source_port": "out",
      "target_port": "in"
    }
  ]
}

Күтілетін нәтиже

order_idamount
101120
10330

Екі жазба, amount қосындысы 150. ORDER BY тексеру файлының ретін бірізді етеді.

Іске қосу және тексеру

  1. Оқу дерекқорында көрсетілген жолдары бар demo_orders және demo_sql қосылымын алдын ала жасаңыз.
  2. Қосылымды тексеріп, дереккөз блогында сұрау режимін таңдаңыз.
  3. Орындап, 101/103 ID тексеріңіз; closed күйіндегі 102 жазбасы нәтижеде болмауы керек.

Жиі қателер

  • Оқуға бір өзгертпейтін сұрау рұқсат етіледі; DDL немесе бірнеше пәрмен енгізбеңіз.
  • Кесте/схема атаулары дерекқорыңызға тәуелді; қажет болса schema.demo_orders қолданыңыз.
  • ORDER BY болмаса, SQL нәтиже реті кепілденбейді.