Object Storage Service:オブジェクトの照会

com.aliyun.oss.mo delをインポートします。*;
com.aliyun.oss.OSSをインポートします。impor t com.aliyun.oss.com mon.auth.*;
com.aliyun.oss.OSSClientBuilderをインポートします。java.io.BufferedReaderをインポートします。java.io.ByteArrayInputStreamをインポートします。java.io.InputStreamReaderをインポートします。/**
 * 選択オブジェクトメタデータと選択オブジェクトの作成例。
 *
 * /
public class SelectObjectSample {
    // バケットが配置されているリージョンのエンドポイントを指定します。 たとえば、バケットが中国 (杭州) リージョンにある場合、エンドポイントをhttps://oss-cn-hangzhou.aliyuncs.comに設定します。 
    プライベート静的文字列エンドポイント="https://oss-cn-hangzhou.aliyuncs.com";
    // バケットの名前を指定します。 例: examplebucket. 
    プライベート静的文字列bucketName = "examplebucket";

    public static void main(String[] args) throws Exception {
      
      	// 環境変数からアクセス資格情報を取得します。 サンプルコードを実行する前に、OSS_ACCESS_KEY_IDおよびOSS_ACCESS_KEY_SECRET環境変数が設定されていることを確認してください。 
        EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
        // Create an OSSClient instance. 
      	OSS ossClient = new OSSClientBuilder().build(endpoint, credentialsProvider);
        // クエリするオブジェクトの完全パスを指定し、SELECTステートメントを使用してオブジェクトのデータをクエリします。 バケット名をフルパスに含めないでください。 
        // CSVオブジェクトのフルパスを指定します。 
        selectCsvSample("test.csv" 、ossClient);
        // JSONオブジェクトのフルパスを指定します。 
        selectJsonSample("test.json" 、ossClient);
        ossClient.shutdown();
    }

    private static void selectCsvSample (文字列キー、OSS ossClient) が例外をスロー {
        // アップロードするオブジェクトのコンテンツを指定します。 
        String content = "name,school,company,age\r\n" +
                "Lora Francis,School A,Staples Inc,27\r\n" +
                "エレノア・リトル、スクールB、\" Conectiv、Inc\"、43\r\n" +
                「ロージー・ヒューズ、スクールC、Western Gas Resources Inc、44\r\n」 +
                「ローレンス・ロス、スクールD、メットライフ社、24」;

        ossClient.putObject(bucketName, key, new ByteArrayInputStream(content.getBytes()));

        SelectObjectMetadata selectObjectMetadata = ossClient.createSelectObjectMetadata ()
                new CreateSelectObjectMetadataRequest(bucketName, key)
                        .withInputSerialization(
                                new InputSerialization().withCsvInputFormat(
                                        // コンテンツ内のさまざまなレコードを区切るために使用される区切り文字を指定します。 例: \r\n。 
                                        新しいCSVFormat().withHeaderInfo(CSVFormat.Header.Use).withRecordDelimiter("\r\n")));
        System.out.println(selectObjectMetadata.getCsvObjectMetadata().getTotalLines());
        System.out.println(selectObjectMetadata.getCsvObjectMetadata().getSplits());

        SelectObjectRequest selectObjectRequest =
                新しいSelectObjectRequest(bucketName, key)
                        .withInputSerialization(
                                new InputSerialization().withCsvInputFormat(
                                        新しいCSVFormat().withHeaderInfo(CSVFormat.Header.Use).withRecordDelimiter("\r\n")))
                        . withOutputSerialization(new OutputSerialization().withCsvOutputFormat(new CSVFormat()));
        // SELECTステートメントを使用して、4番目の列の値が40より大きいすべてのレコードを照会します。 
        selectObjectRequest.setExpression("select * from ossobject where _4 > 40");
        OSSObject ossObject = ossClient.selectObject(selectObjectRequest);

        // オブジェクトの内容を読み取ります。 
        BufferedReader reader = new BufferedReader(new InputStreamReader(ossObject.getObjectContent()));
        一方、（TRUE）{
            String line = reader.readLine();
            if (line == null) {
                break;
            }
            System.out.println (ライン);
        }
        reader.close();

        ossClient.de leteObject(bucketName、key);
    }

    private static void selectJsonSample (文字列キー、OSS ossClient) が例外をスロー {
        // アップロードするオブジェクトのコンテンツを指定します。 
        final String content = "{\n" +
                "\t\" name\": \" Lora Francis\",\n" +
                "\t\" age\": 27,\n" +
                "\t\" company\": \" ステープルズ株式会社 \"\n" +
                "}\n" +
                "{\n" +
                "\t\" name\": \" Eleanor Little\",\n" +
                "\t\" age\": 43,\n" +
                "\t\" company\": \" Conectiv、Inc\"\n" +
                "}\n" +
                "{\n" +
                "\t\" name\": \" Rosie Hughes\",\n" +
                "\t\" age\": 44,\n" +
                "\t\" company\": \" Western Gas Resources Inc\"\n" +
                "}\n" +
                "{\n" +
                "\t\" name\": \" ローレンス・ロス \",\n" +
                "\t\" age\": 24,\n" +
                "\t\" 会社 \": \" メットライフ株式会社 \"\n" +
                "}";

        ossClient.putObject(bucketName, key, new ByteArrayInputStream(content.getBytes()));

        SelectObjectRequest selectObjectRequest =
                新しいSelectObjectRequest(bucketName, key)
                        . withInputSerialization(new InputSerialization())
                                . withCompressionType(CompressionType.NONE)
                                . withJsonInputFormat(new JsonFormat().withJsonType(JsonType.LINES)))
                        . withOutputSerialization(new OutputSerialization())
                                . withCrcEnabled(true)
                                . withJsonOutputFormat (新しいJsonFormat())
                        . withExpression("select * from ossobject as s where s.age > 40"); // SELECTステートメントを使用して、オブジェクト内のデータを照会します。 

        OSSObject ossObject = ossClient.selectObject(selectObjectRequest);

        // オブジェクトの内容を読み取ります。 
        BufferedReader reader = new BufferedReader(new InputStreamReader(ossObject.getObjectContent()));
        一方、（TRUE）{
            String line = reader.readLine();
            if (line == null) {
                break;
            }
            System.out.println (ライン);
        }
        reader.close();

        ossClient.de leteObject(bucketName、key);
    }
} 

インポートoss2
oss2.credentialsからEnvironmentVariableCredentialsProviderをインポート

def select_call_back(consumed_bytes, total_bytes=なし):
        print('Consumed Bytes:'+ str(consumed_bytes) +'\n')

# 環境変数からアクセス資格情報を取得します。 サンプルコードを実行する前に、OSS_ACCESS_KEY_IDおよびOSS_ACCESS_KEY_SECRET環境変数が設定されていることを確認してください。 
auth = oss2.ProviderAuth(EnvironmentVariableCredentialsProvider())
# バケットが配置されているリージョンのエンドポイントを指定します。 たとえば、バケットが中国 (杭州) リージョンにある場合、エンドポイントをhttps://oss-cn-hangzhou.aliyuncs.comに設定します。 
# バケットの名前を指定します。 
bucket = oss2.Bucket(auth, 'https:// oss-cn-hangzhou.aliyuncs.com ', 'examplebucket')
key = 'python_select.csv'
content = 'トム・ハンクス、米国、45\r\n' * 1024
filename = 'python_select.csv'

# CSVファイルをアップロードします。 
bucket.put_object (キー、コンテンツ)
# SelectObject操作のパラメーターを設定します。 
csv_meta_params = {'RecordDelimiter': '\r\n'}
select_csv_params = {'CsvHeaderInfo ': 'None' 、
                    'RecordDelimiter': '\r\n',
                    'LineRange' :( 500、1000)}

csv_header = bucket.create_select_object_meta(key, csv_meta_params)
プリント (csv_header.rows)
print(csv_header.splits)
result = bucket.select_object(key, "select * from ossobject where _3 > 44", select_call_back, select_csv_params)
select_content = result.read()
印刷 (select_content)

result = bucket.select_object_to_file (キー、ファイル名、
      "select * from ossobject where _3 > 44", select_call_back, select_csv_params)
bucket.de lete_object (キー)

### JSONドキュメント
key = 'python_select.json'
content = "{\" contacts\":[{\" key1\":1,\" key2\":\" hello world1\"},{\" key1\":2,\" key2\":\" hello world2\"}]}"
filename = 'python_select.json'
# JSON DOCUMENTオブジェクトをアップロードします。 
bucket.put_object (キー、コンテンツ)
select_json_params = {'Json_Type': 'DOCUMENT'}
result = bucket.select_object(key, "select s.key2 from ossobject.contacts[*] s where s.key1 = 1", None, select_json_params)
select_content = result.read()
印刷 (select_content)

result = bucket.select_object_to_file (キー、ファイル名、
      "select s.key2 from ossobject.contacts[*] s where s.key1 = 1", None, select_json_params)
bucket.de lete_object (キー)

### JSONリンク
key = 'python_select_lines.json'
content = "{\" key1\":1,\" key2\":\" hello world1\"}\n{\" key1\":2,\" key2\":\" hello world2\"}"
filename = 'python_select.json'
# JSON LINESオブジェクトをアップロードします。 
bucket.put_object (キー、コンテンツ)
select_json_params = {'Json_Type': 'LINES'}
json_header = bucket.create_select_object_meta(key,select_json_params)
プリント (json_header.rows)
print(json_header.splits)

result = bucket.select_object(key, "select s.key2 from ossobject s where s.key1 = 1", None, select_json_params)
select_content = result.read()
印刷 (select_content)
result = bucket.select_object_to_file (キー、ファイル名、
           "select s.key2 from ossobject s where s.key1 = 1", None, select_json_params)
bucket.de lete_object(key) 

パッケージメイン

import (import (import)
"fmt"
「github.com/aliyun/aliyun-oss-go-sdk/oss」
"io/ioutil"
"os"
)

func main() {
// 環境変数からアクセス資格情報を取得します。 サンプルコードを実行する前に、OSS_ACCESS_KEY_IDおよびOSS_ACCESS_KEY_SECRET環境変数が設定されていることを確認してください。 
	provider, err := oss.NewEnvironmentVariableCredentialsProvider()
if err! =nil {
fmt.Println("Error:", err)
os.Exit(-1)
}
// OSSClientインスタンスを作成します。 
	// バケットが配置されているリージョンのエンドポイントを指定します。 たとえば、バケットが中国 (杭州) リージョンにある場合、エンドポイントをhttps://oss-cn-hangzhou.aliyuncs.comに設定します。 実際のエンドポイントを指定します。 
	client, err := oss.New("yourEndpoint", ", " ", ", oss.SetCredentialsProvider(&provider))
if err! =nil {
fmt.Println("Error:", err)
os.Exit(-1)
}
// バケットの名前を指定します。 例: examplebucket. 
	bucket, err := client.Bucket("examplebucket")
if err! =nil {
fmt.Println("Error:", err)
os.Exit(-1)
}
// オブジェクトのフルパスを指定します。 バケット名をフルパスに含めないでください。 例: exampledir/exampledata.csv. 
	キー:= "exampledir/exampledata.csv"
// ローカルCSVファイルのフルパスを指定します。 例: D :\\ localpath\\exampledata.csv。 
	localCsvFile := "D :\\ localpath\\exampledata.csv"
err = bucket.PutObjectFromFile (キー、localCsvFile)
if err! =nil {
fmt.Println("Error:", err)
os.Exit(-1)
}

selReq := oss.SelectRequest{}
// SELECTステートメントを実行して、オブジェクト内のデータを照会します。 
	selReq.Expression = 'select * from ossobject'
body, err := bucket.SelectObject(key, selReq)

if err! =nil {
fmt.Println("Error:", err)
os.Exit(-1)
}
// オブジェクトの内容を読み取ります。 
	fc, err := ioutil.ReadAll(body)

if err! =nil {
fmt.Println("Error:", err)
os.Exit(-1)
}
defer body.Close()
fmt.Println (文字列 (fc))
}