PostgreSQL
 sql >> डेटाबेस >  >> RDS >> PostgreSQL

बीम पाइपलाइन से गूगल क्लाउड एसक्यूएल पोस्टग्रेज इंस्टेंस कनेक्ट करें

आप relational_db.लिखें . का उपयोग कर सकते हैं और relational_db.पढ़ें बीम-नगेट्स से रूपांतरित होता है इस प्रकार है:

पहले बीम-नगस्ट स्थापित करें:

pip install beam-nuggets

पढ़ने के लिए:

import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions
from beam_nuggets.io import relational_db

with beam.Pipeline(options=PipelineOptions()) as p:
    source_config = relational_db.SourceConfiguration(
        drivername='postgresql+pg8000',
        host='localhost',
        port=5432,
        username='postgres',
        password='password',
        database='calendar',
    )
    records = p | "Reading records from db" >> relational_db.Read(
        source_config=source_config,
        table_name='months',
    )
    records | 'Writing to stdout' >> beam.Map(print)

लिखने के लिए:

import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions
from beam_nuggets.io import relational_db

with beam.Pipeline(options=PipelineOptions()) as p:
    months = p | "Reading month records" >> beam.Create([
        {'name': 'Jan', 'num': 1},
        {'name': 'Feb', 'num': 2},
    ])
    source_config = relational_db.SourceConfiguration(
        drivername='postgresql+pg8000',
        host='localhost',
        port=5432,
        username='postgres',
        password='password',
        database='calendar',
        create_if_missing=True,
    )
    table_config = relational_db.TableConfiguration(
        name='months',
        create_if_missing=True
    )
    months | 'Writing to DB' >> relational_db.Write(
        source_config=source_config,
        table_config=table_config
    )


  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. पोस्टग्रेज में व्याख्या विश्लेषण से परिणामों की व्याख्या करना

  2. स्प्रिंग बूट, पोस्टग्रेएसक्यूएल और डॉकर - कंटेनर में चलने के दौरान कनेक्शन अस्वीकृत

  3. chown:/var/lib/postgresql/data/postgresql.conf:रीड ओनली फाइल सिस्टम

  4. संख्यात्मक रूप से चार कॉलम द्वारा ऑर्डर करें

  5. x एक प्रक्रिया है, कॉल का उपयोग करें जब मैं पहले से ही कॉल का उपयोग कर रहा हूं